Package | Description |
---|---|
org.apache.flink.table.api | |
org.apache.flink.table.api.java | |
org.apache.flink.table.api.scala |
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 |
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)
Joins this
Table with an user-defined TableFunction . |
Table |
Table.leftOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.leftOuterJoin(Table right,
String joinPredicate)
Joins two
Table s. |
Table |
Table.limit(int offset)
Limits a sorted result from an offset position.
|
Table |
Table.limit(int offset,
int fetch)
Limits a sorted result to a specified number of records from an offset position.
|
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 |
TableEnvironment.scan(scala.collection.Seq<String> tablePath)
Scans a registered table and returns the resulting
Table . |
Table |
TableEnvironment.scan(String... tablePath)
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 |
OverWindowedTable.select(scala.collection.Seq<Expression> fields) |
Table |
WindowGroupedTable.select(scala.collection.Seq<Expression> fields)
Performs a selection operation on a window 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 |
OverWindowedTable.select(String fields) |
Table |
WindowGroupedTable.select(String fields)
Performs a selection operation on a window grouped table.
|
Table |
TableEnvironment.sql(String query)
Evaluates a SQL query on registered tables and retrieves the result as a
Table . |
Table |
WindowedTable.table() |
Table |
GroupedTable.table() |
Table |
OverWindowedTable.table() |
Table |
WindowGroupedTable.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 |
StreamTableEnvironment.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)
Joins this
Table with an user-defined TableFunction . |
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> DataStream<A> |
StreamTableEnvironment.translate(Table table,
StreamQueryConfig queryConfig,
boolean updatesAsRetraction,
boolean withChangeFlag,
TypeInformation<A> tpe)
Translates a
Table into a DataStream . |
protected <A> DataSet<A> |
BatchTableEnvironment.translate(Table table,
TypeInformation<A> tpe)
Translates a
Table into a DataSet . |
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,
QueryConfig queryConfig)
Writes a
Table to a TableSink . |
<T> void |
StreamTableEnvironment.writeToSink(Table table,
TableSink<T> sink,
QueryConfig queryConfig)
Writes a
Table to a TableSink . |
abstract <T> void |
TableEnvironment.writeToSink(Table table,
TableSink<T> sink,
QueryConfig conf)
Writes a
Table to a TableSink . |
Constructor and Description |
---|
GroupedTable(Table table,
scala.collection.Seq<Expression> groupKey) |
OverWindowedTable(Table table,
OverWindow[] overWindows) |
WindowedTable(Table table,
Window window) |
WindowGroupedTable(Table table,
scala.collection.Seq<Expression> groupKeys,
Window window) |
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> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
Class<T> clazz)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
TypeInformation<T> typeInfo)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig)
Converts the given
Table into an append DataStream of a specified type. |
<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)
Deprecated.
This method only supports conversion of append-only tables. In order to
make this more explicit in the future, please use toAppendStream() instead.
|
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig)
Deprecated.
This method only supports conversion of append-only tables. In order to
make this more explicit in the future, please use toAppendStream() instead.
|
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
TypeInformation<T> typeInfo)
Deprecated.
This method only supports conversion of append-only tables. In order to
make this more explicit in the future, please use toAppendStream() instead.
|
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig)
Deprecated.
This method only supports conversion of append-only tables. In order to
make this more explicit in the future, please use toAppendStream() instead.
|
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironment.toRetractStream(Table table,
Class<T> clazz)
Converts the given
Table into a DataStream of add and retract messages. |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironment.toRetractStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig)
Converts the given
Table into a DataStream of add and retract messages. |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironment.toRetractStream(Table table,
TypeInformation<T> typeInfo)
Converts the given
Table into a DataStream of add and retract messages. |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironment.toRetractStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig)
Converts the given
Table into a DataStream of add and retract messages. |
Modifier and Type | Method and Description |
---|---|
Table |
TableFunctionConversions.apply(scala.collection.Seq<Expression> args,
TypeInformation<T> typeInfo)
Creates a
Table from a TableFunction in Scala Table API. |
<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> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
StreamQueryConfig queryConfig,
TypeInformation<T> evidence$4)
Converts the given
Table into an append DataStream of a specified type. |
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
TypeInformation<T> evidence$3)
Converts the given
Table into an append DataStream of a specified type. |
<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,
StreamQueryConfig queryConfig,
TypeInformation<T> evidence$2)
Deprecated.
This method only supports conversion of append-only tables. In order to make this more explicit in the future, please use toAppendStream() instead. Since .
|
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
TypeInformation<T> evidence$1)
Deprecated.
This method only supports conversion of append-only tables. In order to make this more explicit in the future, please use toAppendStream() instead. Since .
|
<T> DataStream<scala.Tuple2<Object,T>> |
StreamTableEnvironment.toRetractStream(Table table,
StreamQueryConfig queryConfig,
TypeInformation<T> evidence$6)
Converts the given
Table into a DataStream of add and retract messages. |
<T> DataStream<scala.Tuple2<Object,T>> |
StreamTableEnvironment.toRetractStream(Table table,
TypeInformation<T> evidence$5)
Converts the given
Table into a DataStream of add and retract messages. |
Constructor and Description |
---|
TableConversions(Table table) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.