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 |
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(Expression udtf)
Joins this
Table to a user-defined TableFunction . |
Table |
Table.join(String udtf)
Joins this
Table to a user-defined TableFunction . |
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(Expression udtf)
Joins this
Table to a user-defined TableFunction . |
Table |
Table.leftOuterJoin(String udtf)
Joins this
Table to a 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 |
BatchTableEnvironment.scan(String tableName)
Scans a registered table and returns the resulting
Table . |
Table |
WindowGroupedTable.select(scala.collection.Seq<Expression> fields)
Performs a selection operation on a window grouped table.
|
Table |
GroupedTable.select(scala.collection.Seq<Expression> fields)
Performs a selection operation on a grouped table.
|
Table |
Table.select(scala.collection.Seq<Expression> fields)
Performs a selection operation.
|
Table |
WindowGroupedTable.select(String fields)
Performs a selection operation on a window grouped table.
|
Table |
GroupedTable.select(String fields)
Performs a selection operation on a grouped table.
|
Table |
Table.select(String fields)
Performs a selection operation.
|
abstract Table |
TableEnvironment.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 . |
Table |
BatchTableEnvironment.sql(String query)
Evaluates a SQL query on registered tables and retrieves the result as a
Table . |
Table |
WindowGroupedTable.table() |
Table |
GroupedTable.table() |
Table |
WindowedTable.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 |
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)
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> DataStream<A> |
StreamTableEnvironment.translate(Table table,
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. |
abstract <T> void |
TableEnvironment.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 . |
<T> void |
BatchTableEnvironment.writeToSink(Table table,
TableSink<T> sink)
Writes a
Table to a TableSink . |
Constructor and Description |
---|
GroupedTable(Table table,
scala.collection.Seq<Expression> groupKey) |
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> 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) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.