Package | Description |
---|---|
org.apache.flink.api.java.table | |
org.apache.flink.api.scala.table | |
org.apache.flink.api.table |
Modifier and Type | Method and Description |
---|---|
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet)
Converts the given
DataSet into a Table . |
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet,
String fields)
Converts the given
DataSet into a Table with specified field names. |
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream)
Converts the given
DataStream into a Table . |
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream,
String fields)
Converts the given
DataStream into a Table with specified field names. |
Modifier and Type | Method and Description |
---|---|
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
Class<T> clazz)
Converts the given
Table into a DataSet of a specified type. |
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
TypeInformation<T> typeInfo)
Converts the given
Table into a DataSet of a specified type. |
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
Class<T> clazz)
Converts the given
Table into a DataStream of a specified type. |
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
TypeInformation<T> typeInfo)
Converts the given
Table into a DataStream of a specified type. |
Modifier and Type | Method and Description |
---|---|
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet)
Converts the given
DataSet into a Table . |
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet,
scala.collection.Seq<Expression> fields)
Converts the given
DataSet into a Table with specified field names. |
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream)
Converts the given
DataStream into a Table . |
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream,
scala.collection.Seq<Expression> fields)
Converts the given
DataStream into a Table with specified field names. |
Table |
DataSetConversions.toTable(BatchTableEnvironment tableEnv,
scala.collection.Seq<Expression> fields)
Converts the
DataSet into a Table . |
Table |
DataStreamConversions.toTable(StreamTableEnvironment tableEnv,
scala.collection.Seq<Expression> fields)
Converts the
DataStream into a Table . |
Modifier and Type | Method and Description |
---|---|
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
TypeInformation<T> evidence$1)
Converts the given
Table into a DataSet of a specified type. |
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
TypeInformation<T> evidence$1)
Converts the given
Table into a DataStream of a specified type. |
Constructor and Description |
---|
TableConversions(Table table) |
Modifier and Type | Method and Description |
---|---|
Table |
Table.as(scala.collection.Seq<Expression> fields)
Renames the fields of the expression result.
|
Table |
Table.as(String fields)
Renames the fields of the expression result.
|
Table |
Table.distinct()
Removes duplicate values and returns only distinct (different) values.
|
Table |
Table.filter(Expression predicate)
Filters out elements that don't pass the filter predicate.
|
Table |
Table.filter(String predicate)
Filters out elements that don't pass the filter predicate.
|
Table |
Table.fullOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.fullOuterJoin(Table right,
String joinPredicate)
Joins two
Table s. |
Table |
StreamTableEnvironment.ingest(String tableName)
Ingests a registered table and returns the resulting
Table . |
Table |
Table.intersect(Table right)
Intersects two
Table s with duplicate records removed. |
Table |
Table.intersectAll(Table right)
Intersects two
Table s. |
Table |
Table.join(Table right)
Joins two
Table s. |
Table |
Table.join(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.join(Table right,
String joinPredicate)
Joins two
Table s. |
Table |
Table.leftOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.leftOuterJoin(Table right,
String joinPredicate)
Joins two
Table s. |
Table |
Table.minus(Table right)
Minus of two
Table s with duplicate records removed. |
Table |
Table.minusAll(Table right)
Minus of two
Table s. |
Table |
Table.orderBy(scala.collection.Seq<Expression> fields)
Sorts the given
Table . |
Table |
Table.orderBy(String fields)
Sorts the given
Table . |
Table |
Table.rightOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.rightOuterJoin(Table right,
String joinPredicate)
Joins two
Table s. |
Table |
BatchTableEnvironment.scan(String tableName)
Scans a registered table and returns the resulting
Table . |
Table |
Table.select(scala.collection.Seq<Expression> fields)
Performs a selection operation.
|
Table |
GroupedTable.select(scala.collection.Seq<Expression> fields)
Performs a selection operation on a grouped table.
|
Table |
Table.select(String fields)
Performs a selection operation.
|
Table |
GroupedTable.select(String fields)
Performs a selection operation on a grouped table.
|
Table |
BatchTableEnvironment.sql(String query)
Evaluates a SQL query on registered tables and retrieves the result as a
Table . |
Table |
StreamTableEnvironment.sql(String query)
Evaluates a SQL query on registered tables and retrieves the result as a
Table . |
abstract Table |
TableEnvironment.sql(String query)
Evaluates a SQL query on registered tables and retrieves the result as a
Table . |
Table |
GroupedTable.table() |
Table |
Table.union(Table right)
Unions two
Table s with duplicate records removed. |
Table |
Table.unionAll(Table right)
Unions two
Table s. |
Table |
Table.where(Expression predicate)
Filters out elements that don't pass the filter predicate.
|
Table |
Table.where(String predicate)
Filters out elements that don't pass the filter predicate.
|
Modifier and Type | Method and Description |
---|---|
String |
BatchTableEnvironment.explain(Table table)
Returns the AST of the specified Table API and SQL queries and the execution plan to compute
the result of the given
Table . |
String |
BatchTableEnvironment.explain(Table table,
boolean extended)
Returns the AST of the specified Table API and SQL queries and the execution plan to compute
the result of the given
Table . |
Table |
Table.fullOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.fullOuterJoin(Table right,
String joinPredicate)
Joins two
Table s. |
Table |
Table.intersect(Table right)
Intersects two
Table s with duplicate records removed. |
Table |
Table.intersectAll(Table right)
Intersects two
Table s. |
Table |
Table.join(Table right)
Joins two
Table s. |
Table |
Table.join(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.join(Table right,
String joinPredicate)
Joins two
Table s. |
Table |
Table.leftOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.leftOuterJoin(Table right,
String joinPredicate)
Joins two
Table s. |
Table |
Table.minus(Table right)
Minus of two
Table s with duplicate records removed. |
Table |
Table.minusAll(Table right)
Minus of two
Table s. |
void |
TableEnvironment.registerTable(String name,
Table table)
Registers a
Table under a unique name in the TableEnvironment's catalog. |
Table |
Table.rightOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.rightOuterJoin(Table right,
String joinPredicate)
Joins two
Table s. |
protected <A> DataSet<A> |
BatchTableEnvironment.translate(Table table,
TypeInformation<A> tpe)
Translates a
Table into a DataSet . |
protected <A> DataStream<A> |
StreamTableEnvironment.translate(Table table,
TypeInformation<A> tpe)
Translates a
Table into a DataStream . |
Table |
Table.union(Table right)
Unions two
Table s with duplicate records removed. |
Table |
Table.unionAll(Table right)
Unions two
Table s. |
<T> void |
BatchTableEnvironment.writeToSink(Table table,
TableSink<T> sink)
Writes a
Table to a TableSink . |
<T> void |
StreamTableEnvironment.writeToSink(Table table,
TableSink<T> sink)
Writes a
Table to a TableSink . |
abstract <T> void |
TableEnvironment.writeToSink(Table table,
TableSink<T> sink)
Writes a
Table to a TableSink . |
Constructor and Description |
---|
GroupedTable(Table table,
scala.collection.Seq<Expression> groupKey) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.