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.from(TableDescriptor descriptor)
Returns a
Table backed by the given descriptor . |
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 |
Table.select(Expression... fields)
Performs a selection operation.
|
Table |
OverWindowedTable.select(Expression... fields)
Performs a selection operation on a over windowed table.
|
Table |
GroupedTable.select(Expression... fields)
Performs a selection operation on a grouped table.
|
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 |
WindowGroupedTable.select(Expression... fields)
Performs a selection operation on a window grouped table.
|
Table |
Table.select(String fields)
Deprecated.
|
Table |
OverWindowedTable.select(String fields)
Deprecated.
|
Table |
GroupedTable.select(String fields)
Deprecated.
|
Table |
AggregatedTable.select(String fields)
Deprecated.
|
Table |
FlatAggregateTable.select(String fields)
Deprecated.
|
Table |
WindowGroupedTable.select(String fields)
Deprecated.
|
Table |
TableEnvironment.sqlQuery(String query)
Evaluates a SQL query on registered tables and returns a
Table object describing the
pipeline for further transformations. |
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)
Shorthand for
statementSet.add(table.insertInto(targetPath)) . |
StatementSet |
StatementSet.addInsert(String targetPath,
Table table,
boolean overwrite)
Shorthand for
statementSet.add(table.insertInto(targetPath, overwrite)) . |
StatementSet |
StatementSet.addInsert(TableDescriptor targetDescriptor,
Table table)
Shorthand for
statementSet.add(table.insertInto(targetDescriptor)) . |
StatementSet |
StatementSet.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite)
Shorthand for
statementSet.add(table.insertInto(targetDescriptor, overwrite)) . |
void |
TableEnvironment.createTemporaryView(String path,
Table view)
Registers a
Table API object as a temporary view similar to SQL temporary views. |
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.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 |
---|---|
protected <T> Table |
AbstractStreamTableEnvironmentImpl.fromStreamInternal(DataStream<T> dataStream,
Schema schema,
String viewPath,
ChangelogMode changelogMode) |
Modifier and Type | Method and Description |
---|---|
protected <T> TypeInformation<T> |
AbstractStreamTableEnvironmentImpl.extractTypeInformation(Table table,
Class<T> clazz) |
protected <T> DataStream<T> |
AbstractStreamTableEnvironmentImpl.toStreamInternal(Table table,
ModifyOperation modifyOperation) |
protected <T> DataStream<T> |
AbstractStreamTableEnvironmentImpl.toStreamInternal(Table table,
SchemaTranslator.ProducingResult schemaTranslationResult,
ChangelogMode changelogMode) |
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 |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream)
Converts the given
DataStream into a Table . |
<T> Table |
StreamTableEnvironment.fromDataStream(DataStream<T> dataStream,
Expression... fields)
Deprecated.
Use
StreamTableEnvironment.fromDataStream(DataStream, Schema) instead. In most cases, StreamTableEnvironment.fromDataStream(DataStream) should already be sufficient. It integrates with the new
type system and supports all kinds of DataTypes that the table runtime can
consume. The semantics might be slightly different for raw and structured types. |
<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 |
---|---|
StreamStatementSet |
StreamStatementSet.addInsert(String targetPath,
Table table) |
StreamStatementSet |
StreamStatementSet.addInsert(String targetPath,
Table table,
boolean overwrite) |
StreamStatementSet |
StreamStatementSet.addInsert(TableDescriptor targetDescriptor,
Table table) |
StreamStatementSet |
StreamStatementSet.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite) |
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
Class<T> clazz)
Deprecated.
Use
StreamTableEnvironment.toDataStream(Table, Class) instead. It integrates with the new type
system and supports all kinds of DataTypes that the table runtime can produce.
The semantics might be slightly different for raw and structured types. Use toDataStream(DataTypes.of(TypeInformation.of(Class))) if TypeInformation should
be used as source of truth. |
<T> DataStream<T> |
StreamTableEnvironment.toAppendStream(Table table,
TypeInformation<T> typeInfo)
Deprecated.
Use
StreamTableEnvironment.toDataStream(Table, Class) instead. It integrates with the new type
system and supports all kinds of DataTypes that the table runtime can produce.
The semantics might be slightly different for raw and structured types. Use toDataStream(DataTypes.of(TypeInformation.of(Class))) if TypeInformation should
be used as source of truth. |
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. |
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)
Deprecated.
Use
StreamTableEnvironment.toChangelogStream(Table, Schema) instead. It integrates with the new
type system and supports all kinds of DataTypes and every ChangelogMode
that the table runtime can produce. |
<T> DataStream<Tuple2<Boolean,T>> |
StreamTableEnvironment.toRetractStream(Table table,
TypeInformation<T> typeInfo)
Deprecated.
Use
StreamTableEnvironment.toChangelogStream(Table, Schema) instead. It integrates with the new
type system and supports all kinds of DataTypes and every ChangelogMode
that the table runtime can produce. |
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 |
---|---|
StreamStatementSet |
StreamStatementSetImpl.addInsert(String targetPath,
Table table) |
StreamStatementSet |
StreamStatementSetImpl.addInsert(String targetPath,
Table table,
boolean overwrite) |
StreamStatementSet |
StreamStatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table) |
StreamStatementSet |
StreamStatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite) |
<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.from(TableDescriptor descriptor) |
Table |
TableEnvironmentInternal.fromTableSource(TableSource<?> source)
Deprecated.
|
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 |
---|---|
StatementSet |
StatementSetImpl.addInsert(String targetPath,
Table table) |
StatementSet |
StatementSetImpl.addInsert(String targetPath,
Table table,
boolean overwrite) |
StatementSet |
StatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table) |
StatementSet |
StatementSetImpl.addInsert(TableDescriptor targetDescriptor,
Table table,
boolean overwrite) |
void |
TableEnvironmentImpl.createTemporaryView(String path,
Table view) |
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.
|
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–2023 The Apache Software Foundation. All rights reserved.