Modifier and Type | Method and Description |
---|---|
Table |
Table.addColumns(Expression... fields)
Adds additional columns.
|
Table |
Table.addOrReplaceColumns(Expression... fields)
Adds additional columns.
|
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.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.flatMap(Expression tableFunction)
Performs a flatMap operation with an user-defined table function or built-in table function.
|
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.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.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.leftOuterJoin(Table right)
Joins two
Table s. |
Table |
Table.leftOuterJoin(Table right,
Expression 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 . |
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.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.renameColumns(Expression... fields)
Renames existing columns.
|
Table |
Table.rightOuterJoin(Table right,
Expression joinPredicate)
Joins two
Table s. |
Table |
TableEnvironment.scan(String... tablePath)
Deprecated.
|
Table |
FlatAggregateTable.select(Expression... fields)
Performs a selection operation on a FlatAggregateTable table.
|
Table |
AggregatedTable.select(Expression... fields)
Performs a selection operation after an aggregate operation.
|
Table |
Table.select(Expression... fields)
Performs a selection operation.
|
Table |
GroupedTable.select(Expression... fields)
Performs a selection operation on a grouped table.
|
Table |
WindowGroupedTable.select(Expression... fields)
Performs a selection operation on a window grouped table.
|
Table |
OverWindowedTable.select(Expression... fields)
Performs a selection operation on a over windowed table.
|
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.
|
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.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.leftOuterJoin(Table right)
Joins two
Table s. |
Table |
Table.leftOuterJoin(Table right,
Expression 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)
Deprecated.
|
Table |
Table.rightOuterJoin(Table right,
Expression 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 | 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 . |
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) |
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.addOrReplaceColumns(Expression... fields) |
Table |
TableImpl.as(Expression... fields) |
Table |
TableImpl.as(String field,
String... fields) |
Table |
TableImpl.distinct() |
Table |
TableImpl.dropColumns(Expression... fields) |
Table |
TableImpl.fetch(int fetch) |
Table |
TableImpl.filter(Expression predicate) |
Table |
TableImpl.flatMap(Expression 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.intersect(Table right) |
Table |
TableImpl.intersectAll(Table right) |
Table |
TableImpl.join(Table right) |
Table |
TableImpl.join(Table right,
Expression joinPredicate) |
Table |
TableImpl.joinLateral(Expression tableFunctionCall) |
Table |
TableImpl.joinLateral(Expression tableFunctionCall,
Expression joinPredicate) |
Table |
TableImpl.leftOuterJoin(Table right) |
Table |
TableImpl.leftOuterJoin(Table right,
Expression joinPredicate) |
Table |
TableImpl.leftOuterJoinLateral(Expression tableFunctionCall) |
Table |
TableImpl.leftOuterJoinLateral(Expression tableFunctionCall,
Expression joinPredicate) |
Table |
TableImpl.map(Expression mapFunction) |
Table |
TableImpl.minus(Table right) |
Table |
TableImpl.minusAll(Table right) |
Table |
TableImpl.offset(int offset) |
Table |
TableImpl.orderBy(Expression... fields) |
Table |
TableImpl.renameColumns(Expression... fields) |
Table |
TableImpl.rightOuterJoin(Table right,
Expression joinPredicate) |
Table |
TableEnvironmentImpl.scan(String... tablePath) |
Table |
TableImpl.select(Expression... fields) |
Table |
TableEnvironmentImpl.sqlQuery(String query) |
Table |
TableImpl.union(Table right) |
Table |
TableImpl.unionAll(Table right) |
Table |
TableImpl.where(Expression 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) |
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.leftOuterJoin(Table right) |
Table |
TableImpl.leftOuterJoin(Table right,
Expression 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.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.
|
Modifier and Type | Method and Description |
---|---|
static Table |
PythonTableUtils.createTableFromElement(TableEnvironment tEnv,
String filePath,
DataType schema,
boolean batched)
Create a table from
PythonDynamicTableSource that read data from input file with
specific DataType . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.