Modifier and Type | Method and Description |
---|---|
Table |
Transformer.transform(TableEnvironment tEnv,
Table input)
Applies the transformer on the input table, and returns the result table.
|
Table |
Pipeline.transform(TableEnvironment tEnv,
Table input)
Generate a result table by applying all the stages in this pipeline to the input table in
order.
|
Modifier and Type | Method and Description |
---|---|
M |
Estimator.fit(TableEnvironment tEnv,
Table input)
|
Pipeline |
Pipeline.fit(TableEnvironment tEnv,
Table input)
Train the pipeline to fit on the records in the given
Table . |
Table |
Transformer.transform(TableEnvironment tEnv,
Table input)
Applies the transformer on the input table, and returns the result table.
|
Table |
Pipeline.transform(TableEnvironment tEnv,
Table input)
Generate a result table by applying all the stages in this pipeline to the input table in
order.
|
Modifier and Type | Method and Description |
---|---|
Table |
Table.addColumns(Expression... fields)
Adds additional columns.
|
Table |
Table.addColumns(String fields)
Adds additional columns.
|
Table |
Table.addOrReplaceColumns(Expression... fields)
Adds additional columns.
|
Table |
Table.addOrReplaceColumns(String fields)
Adds additional columns.
|
Table |
Table.as(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.dropColumns(Expression... fields)
Drops existing columns.
|
Table |
Table.dropColumns(String fields)
Drops existing columns.
|
Table |
Table.fetch(int fetch)
Limits a sorted result to the first n rows.
|
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.flatMap(Expression tableFunction)
Performs a flatMap operation with an user-defined table function or built-in table function.
|
Table |
Table.flatMap(String tableFunction)
Performs a flatMap operation with an user-defined table function or built-in table function.
|
Table |
TableEnvironment.fromTableSource(TableSource<?> source)
Creates a table from a table source.
|
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.joinLateral(Expression tableFunctionCall)
Joins this
Table with an user-defined TableFunction . |
Table |
Table.joinLateral(Expression tableFunctionCall,
Expression joinPredicate)
Joins this
Table with an user-defined TableFunction . |
Table |
Table.joinLateral(String tableFunctionCall)
Joins this
Table with an user-defined TableFunction . |
Table |
Table.joinLateral(String tableFunctionCall,
String joinPredicate)
Joins this
Table with an user-defined TableFunction . |
Table |
Table.leftOuterJoin(Table right)
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.leftOuterJoinLateral(Expression tableFunctionCall)
Joins this
Table with an user-defined TableFunction . |
Table |
Table.leftOuterJoinLateral(Expression tableFunctionCall,
Expression joinPredicate)
Joins this
Table with an user-defined TableFunction . |
Table |
Table.leftOuterJoinLateral(String tableFunctionCall)
Joins this
Table with an user-defined TableFunction . |
Table |
Table.leftOuterJoinLateral(String tableFunctionCall,
String joinPredicate)
Joins this
Table with an user-defined TableFunction . |
Table |
Table.map(Expression mapFunction)
Performs a map operation with an user-defined scalar function or built-in scalar function.
|
Table |
Table.map(String mapFunction)
Performs a map operation with an user-defined scalar function or a built-in scalar function.
|
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.offset(int offset)
Limits a sorted result from an offset position.
|
Table |
Table.orderBy(Expression... fields)
Sorts the given
Table . |
Table |
Table.orderBy(String fields)
Sorts the given
Table . |
Table |
Table.renameColumns(Expression... fields)
Renames existing columns.
|
Table |
Table.renameColumns(String fields)
Renames existing columns.
|
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(String... tablePath)
Scans a registered table and returns the resulting
Table . |
Table |
AggregatedTable.select(Expression... fields)
Performs a selection operation after an aggregate operation.
|
Table |
Table.select(Expression... fields)
Performs a selection operation.
|
Table |
FlatAggregateTable.select(Expression... fields)
Performs a selection operation on a FlatAggregateTable table.
|
Table |
GroupedTable.select(Expression... fields)
Performs a selection operation on a grouped table.
|
Table |
OverWindowedTable.select(Expression... fields)
Performs a selection operation on a over windowed table.
|
Table |
WindowGroupedTable.select(Expression... fields)
Performs a selection operation on a window grouped table.
|
Table |
AggregatedTable.select(String fields)
Performs a selection operation after an aggregate operation.
|
Table |
Table.select(String fields)
Performs a selection operation.
|
Table |
FlatAggregateTable.select(String fields)
Performs a selection operation on a FlatAggregateTable.
|
Table |
GroupedTable.select(String fields)
Performs a selection operation on a grouped table.
|
Table |
OverWindowedTable.select(String fields)
Performs a selection operation on a over windowed table.
|
Table |
WindowGroupedTable.select(String fields)
Performs a selection operation on a window grouped table.
|
Table |
TableEnvironment.sqlQuery(String query)
Evaluates a SQL query on registered tables and retrieves the result as a
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 |
TableEnvironment.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 |
TableEnvironment.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. |
void |
TableEnvironment.insertInto(Table table,
String sinkPath,
String... sinkPathContinued)
|
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 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. |
Table |
Table.union(Table right)
Unions two
Table s with duplicate records removed. |
Table |
Table.unionAll(Table right)
Unions two
Table s. |
Modifier and Type | Class and Description |
---|---|
class |
TableImpl
Implementation for
Table . |
Modifier and Type | Method and Description |
---|---|
Table |
TableImpl.addColumns(Expression... fields) |
Table |
TableImpl.addColumns(String fields) |
Table |
TableImpl.addOrReplaceColumns(Expression... fields) |
Table |
TableImpl.addOrReplaceColumns(String fields) |
Table |
TableImpl.as(Expression... fields) |
Table |
TableImpl.as(String fields) |
Table |
TableImpl.distinct() |
Table |
TableImpl.dropColumns(Expression... fields) |
Table |
TableImpl.dropColumns(String fields) |
Table |
TableImpl.fetch(int fetch) |
Table |
TableImpl.filter(Expression predicate) |
Table |
TableImpl.filter(String predicate) |
Table |
TableImpl.flatMap(Expression tableFunction) |
Table |
TableImpl.flatMap(String tableFunction) |
Table |
TableEnvironmentImpl.fromTableSource(TableSource<?> source) |
Table |
TableImpl.fullOuterJoin(Table right,
Expression joinPredicate) |
Table |
TableImpl.fullOuterJoin(Table right,
String joinPredicate) |
Table |
TableImpl.intersect(Table right) |
Table |
TableImpl.intersectAll(Table right) |
Table |
TableImpl.join(Table right) |
Table |
TableImpl.join(Table right,
Expression joinPredicate) |
Table |
TableImpl.join(Table right,
String joinPredicate) |
Table |
TableImpl.joinLateral(Expression tableFunctionCall) |
Table |
TableImpl.joinLateral(Expression tableFunctionCall,
Expression joinPredicate) |
Table |
TableImpl.joinLateral(String tableFunctionCall) |
Table |
TableImpl.joinLateral(String tableFunctionCall,
String joinPredicate) |
Table |
TableImpl.leftOuterJoin(Table right) |
Table |
TableImpl.leftOuterJoin(Table right,
Expression joinPredicate) |
Table |
TableImpl.leftOuterJoin(Table right,
String joinPredicate) |
Table |
TableImpl.leftOuterJoinLateral(Expression tableFunctionCall) |
Table |
TableImpl.leftOuterJoinLateral(Expression tableFunctionCall,
Expression joinPredicate) |
Table |
TableImpl.leftOuterJoinLateral(String tableFunctionCall) |
Table |
TableImpl.leftOuterJoinLateral(String tableFunctionCall,
String joinPredicate) |
Table |
TableImpl.map(Expression mapFunction) |
Table |
TableImpl.map(String mapFunction) |
Table |
TableImpl.minus(Table right) |
Table |
TableImpl.minusAll(Table right) |
Table |
TableImpl.offset(int offset) |
Table |
TableImpl.orderBy(Expression... fields) |
Table |
TableImpl.orderBy(String fields) |
Table |
TableImpl.renameColumns(Expression... fields) |
Table |
TableImpl.renameColumns(String fields) |
Table |
TableImpl.rightOuterJoin(Table right,
Expression joinPredicate) |
Table |
TableImpl.rightOuterJoin(Table right,
String joinPredicate) |
Table |
TableEnvironmentImpl.scan(String... tablePath) |
Table |
TableImpl.select(Expression... fields) |
Table |
TableImpl.select(String fields) |
Table |
TableEnvironmentImpl.sqlQuery(String query) |
Table |
TableImpl.union(Table right) |
Table |
TableImpl.unionAll(Table right) |
Table |
TableImpl.where(Expression predicate) |
Table |
TableImpl.where(String predicate) |
Modifier and Type | Method and Description |
---|---|
String |
TableEnvironmentImpl.explain(Table table) |
String |
TableEnvironmentImpl.explain(Table table,
boolean extended) |
Table |
TableImpl.fullOuterJoin(Table right,
Expression joinPredicate) |
Table |
TableImpl.fullOuterJoin(Table right,
String joinPredicate) |
void |
TableEnvironmentImpl.insertInto(Table table,
String path,
String... pathContinued) |
Table |
TableImpl.intersect(Table right) |
Table |
TableImpl.intersectAll(Table right) |
Table |
TableImpl.join(Table right) |
Table |
TableImpl.join(Table right,
Expression joinPredicate) |
Table |
TableImpl.join(Table right,
String joinPredicate) |
Table |
TableImpl.leftOuterJoin(Table right) |
Table |
TableImpl.leftOuterJoin(Table right,
Expression joinPredicate) |
Table |
TableImpl.leftOuterJoin(Table right,
String joinPredicate) |
Table |
TableImpl.minus(Table right) |
Table |
TableImpl.minusAll(Table right) |
void |
TableEnvironmentImpl.registerTable(String name,
Table table) |
Table |
TableImpl.rightOuterJoin(Table right,
Expression joinPredicate) |
Table |
TableImpl.rightOuterJoin(Table right,
String joinPredicate) |
Table |
TableImpl.union(Table right) |
Table |
TableImpl.unionAll(Table right) |
Modifier and Type | Method and Description |
---|---|
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet)
|
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet,
String fields)
|
<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 |
---|---|
void |
BatchTableEnvironment.insertInto(Table table,
BatchQueryConfig queryConfig,
String sinkPath,
String... sinkPathContinued)
|
void |
StreamTableEnvironment.insertInto(Table table,
StreamQueryConfig queryConfig,
String sinkPath,
String... sinkPathContinued)
|
<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)
|
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
Class<T> clazz,
BatchQueryConfig queryConfig)
|
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
TypeInformation<T> typeInfo)
|
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
TypeInformation<T> typeInfo,
BatchQueryConfig queryConfig)
|
<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 |
---|---|
<T> Table |
StreamTableEnvironmentImpl.fromDataStream(DataStream<T> dataStream) |
<T> Table |
StreamTableEnvironmentImpl.fromDataStream(DataStream<T> dataStream,
String fields) |
Modifier and Type | Method and Description |
---|---|
void |
StreamTableEnvironmentImpl.insertInto(Table table,
StreamQueryConfig queryConfig,
String sinkPath,
String... sinkPathContinued) |
<T> DataStream<T> |
StreamTableEnvironmentImpl.toAppendStream(Table table,
Class<T> clazz) |
<T> DataStream<T> |
StreamTableEnvironmentImpl.toAppendStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig) |
<T> DataStream<T> |
StreamTableEnvironmentImpl.toAppendStream(Table table,
TypeInformation<T> typeInfo) |
<T> DataStream<T> |
StreamTableEnvironmentImpl.toAppendStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig) |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironmentImpl.toRetractStream(Table table,
Class<T> clazz) |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironmentImpl.toRetractStream(Table table,
Class<T> clazz,
StreamQueryConfig queryConfig) |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironmentImpl.toRetractStream(Table table,
TypeInformation<T> typeInfo) |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironmentImpl.toRetractStream(Table table,
TypeInformation<T> typeInfo,
StreamQueryConfig queryConfig) |
Modifier and Type | Method and Description |
---|---|
static TableReferenceExpression |
ApiExpressionUtils.tableRef(String name,
Table table) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.