Modifier and Type | Method and Description |
---|---|
Table |
Table.addColumns(Expression... fields)
Adds additional columns.
|
Table |
Table.addColumns(String fields)
Deprecated.
|
Table |
Table.addOrReplaceColumns(Expression... fields)
Adds additional columns.
|
Table |
Table.addOrReplaceColumns(String fields)
Deprecated.
|
Table |
Table.as(Expression... fields)
Deprecated.
|
Table |
Table.as(String field,
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)
Deprecated.
|
Table |
Table.fetch(int fetch)
Limits a (possibly 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)
Deprecated.
|
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)
Deprecated.
|
Table |
TableEnvironment.from(String path)
Reads a registered table and returns the resulting
Table . |
Table |
TableEnvironment.fromTableSource(TableSource<?> source)
Deprecated.
|
Table |
TableEnvironment.fromValues(AbstractDataType<?> rowType,
Expression... values)
Creates a Table from given collection of objects with a given row type.
|
Table |
TableEnvironment.fromValues(AbstractDataType<?> rowType,
Iterable<?> values)
Creates a Table from given collection of objects with a given row type.
|
default Table |
TableEnvironment.fromValues(AbstractDataType<?> rowType,
Object... values)
Creates a Table from given collection of objects with a given row type.
|
Table |
TableEnvironment.fromValues(Expression... values)
Creates a Table from given values.
|
Table |
TableEnvironment.fromValues(Iterable<?> values)
Creates a Table from given collection of objects.
|
default Table |
TableEnvironment.fromValues(Object... values)
Creates a Table from given values.
|
Table |
Table.fullOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.fullOuterJoin(Table right,
String joinPredicate)
Deprecated.
|
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)
Deprecated.
|
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)
Deprecated.
|
Table |
Table.joinLateral(String tableFunctionCall,
String joinPredicate)
Deprecated.
|
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)
Deprecated.
|
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)
Deprecated.
|
Table |
Table.leftOuterJoinLateral(String tableFunctionCall,
String joinPredicate)
Deprecated.
|
default Table |
Table.limit(int fetch)
Limits a (possibly sorted) result to the first n rows.
|
default Table |
Table.limit(int offset,
int fetch)
Limits a (possibly sorted) result to the first n rows from an offset position.
|
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)
Deprecated.
use
map(Expression) |
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 (possibly sorted) result from an offset position.
|
Table |
Table.orderBy(Expression... fields)
Sorts the given
Table . |
Table |
Table.orderBy(String fields)
Deprecated.
|
Table |
Table.renameColumns(Expression... fields)
Renames existing columns.
|
Table |
Table.renameColumns(String fields)
Deprecated.
|
Table |
Table.rightOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.rightOuterJoin(Table right,
String joinPredicate)
Deprecated.
|
Table |
TableEnvironment.scan(String... tablePath)
Deprecated.
|
Table |
AggregatedTable.select(Expression... fields)
Performs a selection operation after an aggregate 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 |
Table.select(Expression... fields)
Performs a selection operation.
|
Table |
AggregatedTable.select(String fields)
Deprecated.
|
Table |
FlatAggregateTable.select(String fields)
Deprecated.
|
Table |
GroupedTable.select(String fields)
Deprecated.
|
Table |
OverWindowedTable.select(String fields)
Deprecated.
|
Table |
WindowGroupedTable.select(String fields)
Deprecated.
|
Table |
Table.select(String fields)
Deprecated.
|
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)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
StatementSet |
StatementSet.addInsert(String targetPath,
Table table)
add Table with the given sink table name to the set.
|
StatementSet |
StatementSet.addInsert(String targetPath,
Table table,
boolean overwrite)
add
Table with the given sink table name to the set. |
void |
TableEnvironment.createTemporaryView(String path,
Table view)
Registers a
Table API object as a temporary view similar to SQL temporary views. |
String |
TableEnvironment.explain(Table table)
Deprecated.
|
String |
TableEnvironment.explain(Table table,
boolean extended)
Deprecated.
|
Table |
Table.fullOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.fullOuterJoin(Table right,
String joinPredicate)
Deprecated.
|
void |
TableEnvironment.insertInto(String targetPath,
Table table)
Deprecated.
use
executeInsert(String) for single sink, use TableEnvironment.createStatementSet() for multiple sinks. |
void |
TableEnvironment.insertInto(Table table,
String sinkPath,
String... sinkPathContinued)
Deprecated.
use
executeInsert(String) for single sink, use TableEnvironment.createStatementSet() for multiple sinks. |
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)
Deprecated.
|
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)
Deprecated.
|
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)
Deprecated.
|
Table |
Table.rightOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
Table.rightOuterJoin(Table right,
String joinPredicate)
Deprecated.
|
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 | Method and Description |
---|---|
Table |
StreamTableEnvironment.fromChangelogStream(DataStream<Row> dataStream)
Converts the given
DataStream of changelog entries into a Table . |
Table |
StreamTableEnvironment.fromChangelogStream(DataStream<Row> dataStream,
Schema schema)
Converts the given
DataStream of changelog entries into a Table . |
Table |
StreamTableEnvironment.fromChangelogStream(DataStream<Row> dataStream,
Schema schema,
ChangelogMode changelogMode)
Converts the given
DataStream of changelog entries into a Table . |
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet)
Deprecated.
|
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet,
Expression... fields)
Deprecated.
|
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet,
String fields)
Deprecated.
|
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream)
Converts the given
DataStream into a Table . |
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream,
Expression... fields)
Converts the given
DataStream into a Table with specified field names. |
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream,
Schema schema)
Converts the given
DataStream into a Table . |
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream,
String fields)
Deprecated.
|
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,
TypeInformation<T> typeInfo)
Converts the given
Table into an append DataStream of a specified type. |
DataStream<Row> |
StreamTableEnvironment.toChangelogStream(Table table)
Converts the given
Table into a DataStream of changelog entries. |
DataStream<Row> |
StreamTableEnvironment.toChangelogStream(Table table,
Schema targetSchema)
Converts the given
Table into a DataStream of changelog entries. |
DataStream<Row> |
StreamTableEnvironment.toChangelogStream(Table table,
Schema targetSchema,
ChangelogMode changelogMode)
Converts the given
Table into a DataStream of changelog entries. |
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
Class<T> clazz)
Deprecated.
|
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
TypeInformation<T> typeInfo)
Deprecated.
|
DataStream<Row> |
StreamTableEnvironment.toDataStream(Table table)
Converts the given
Table into a DataStream . |
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
AbstractDataType<?> targetDataType)
|
<T> DataStream<T> |
StreamTableEnvironment.toDataStream(Table table,
Class<T> targetClass)
|
<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,
TypeInformation<T> typeInfo)
Converts the given
Table into a DataStream of add and retract messages. |
Modifier and Type | Method and Description |
---|---|
Table |
StreamTableEnvironmentImpl.fromChangelogStream(DataStream<Row> dataStream) |
Table |
StreamTableEnvironmentImpl.fromChangelogStream(DataStream<Row> dataStream,
Schema schema) |
Table |
StreamTableEnvironmentImpl.fromChangelogStream(DataStream<Row> dataStream,
Schema schema,
ChangelogMode changelogMode) |
<T> Table |
StreamTableEnvironmentImpl.fromDataStream(DataStream<T> dataStream) |
<T> Table |
StreamTableEnvironmentImpl.fromDataStream(DataStream<T> dataStream,
Expression... fields) |
<T> Table |
StreamTableEnvironmentImpl.fromDataStream(DataStream<T> dataStream,
Schema schema) |
<T> Table |
StreamTableEnvironmentImpl.fromDataStream(DataStream<T> dataStream,
String fields) |
Modifier and Type | Method and Description |
---|---|
<T> DataStream<T> |
StreamTableEnvironmentImpl.toAppendStream(Table table,
Class<T> clazz) |
<T> DataStream<T> |
StreamTableEnvironmentImpl.toAppendStream(Table table,
TypeInformation<T> typeInfo) |
DataStream<Row> |
StreamTableEnvironmentImpl.toChangelogStream(Table table) |
DataStream<Row> |
StreamTableEnvironmentImpl.toChangelogStream(Table table,
Schema targetSchema) |
DataStream<Row> |
StreamTableEnvironmentImpl.toChangelogStream(Table table,
Schema targetSchema,
ChangelogMode changelogMode) |
DataStream<Row> |
StreamTableEnvironmentImpl.toDataStream(Table table) |
<T> DataStream<T> |
StreamTableEnvironmentImpl.toDataStream(Table table,
AbstractDataType<?> targetDataType) |
<T> DataStream<T> |
StreamTableEnvironmentImpl.toDataStream(Table table,
Class<T> targetClass) |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironmentImpl.toRetractStream(Table table,
Class<T> clazz) |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironmentImpl.toRetractStream(Table table,
TypeInformation<T> typeInfo) |
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 field,
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.from(String path) |
Table |
TableEnvironmentImpl.fromTableSource(TableSource<?> source) |
Table |
TableEnvironmentImpl.fromValues(AbstractDataType<?> rowType,
Expression... values) |
Table |
TableEnvironmentImpl.fromValues(AbstractDataType<?> rowType,
Iterable<?> values) |
Table |
TableEnvironmentImpl.fromValues(AbstractDataType<?> rowType,
Object... values) |
Table |
TableEnvironmentImpl.fromValues(Expression... values) |
Table |
TableEnvironmentImpl.fromValues(Iterable<?> values) |
Table |
TableEnvironmentImpl.fromValues(Object... values) |
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 |
---|---|
void |
TableEnvironmentImpl.createTemporaryView(String path,
Table view) |
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) |
OutType |
BaseExpressions.in(Table table)
Returns true if an expression exists in a given table sub-query.
|
void |
TableEnvironmentImpl.insertInto(String targetPath,
Table table) |
void |
TableEnvironmentImpl.insertInto(Table table,
String sinkPath,
String... sinkPathContinued) |
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 |
---|---|
static TableReferenceExpression |
ApiExpressionUtils.tableRef(String name,
Table table) |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.table.runtime.arrow.ArrowUtils.CustomIterator<byte[]> |
ArrowUtils.collectAsPandasDataFrame(Table table,
int maxArrowBatchSize)
Convert Flink table to Pandas DataFrame.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.