Uses of Interface
org.apache.flink.table.api.Table

Packages that use Table

Package	Description
io.confluent.flink.plugin
org.apache.flink.table.api
org.apache.flink.table.api.internal

Uses of Table in io.confluent.flink.plugin

Methods in io.confluent.flink.plugin with parameters of type Table

Modifier and Type	Method	Description
static List<Row>	ConfluentTools.collectChangelog(Table table)	Executes the given table transformations on Confluent Cloud and returns the results locally as a list of changelog rows.
static List<Row>	ConfluentTools.collectChangelog(Table table, int stopAfter)	Executes the given table transformations on Confluent Cloud and returns the results locally as a list of changelog rows.
static List<Row>	ConfluentTools.collectMaterialized(Table table)	Executes the given table transformations on Confluent Cloud and returns the results locally as a materialized changelog.
static List<Row>	ConfluentTools.collectMaterialized(Table table, int stopAfter)	Executes the given table transformations on Confluent Cloud and returns the results locally as a materialized changelog.
static void	ConfluentTools.printChangelog(Table table)	Executes the given table transformations on Confluent Cloud and prints the results locally as a table prefixed with a change flag column.
static void	ConfluentTools.printChangelog(Table table, int stopAfter)	Executes the given table transformations on Confluent Cloud and prints the results locally as a table prefixed with a change flag column.
static void	ConfluentTools.printMaterialized(Table table)	Executes the given table transformations on Confluent Cloud and prints the results locally as a materialized changelog.
static void	ConfluentTools.printMaterialized(Table table, int stopAfter)	Executes the given table transformations on Confluent Cloud and prints the results locally as a materialized changelog.

Uses of Table in org.apache.flink.table.api

Methods in org.apache.flink.table.api that return Table

Modifier and Type	Method	Description
Table	Table.addColumns(Expression... fields)	Adds additional columns.
Table	Table.addOrReplaceColumns(Expression... fields)	Adds additional columns.
Table	Table.as(String field, String... fields)	Renames the fields of the expression result.
Table	Table.as(Expression... fields)	Deprecated. use as(String, String...)
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.fromCall(Class<? extends UserDefinedFunction> function, Object... arguments)	Returns a Table backed by a call to a process table function (PTF).
Table	TableEnvironment.fromCall(String path, Object... arguments)	Returns a Table backed by a call to a process table function (PTF).
Table	Table.fromChangelog(Expression... arguments)	Converts this append-only table with an explicit operation code column into a (potentially updating) dynamic table.
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	TableEnvironment.fromValues(Expression... values)	Creates a Table from given values.
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(AbstractDataType<?> rowType, Expression... values)	Creates a Table from given collection of objects with a given row type.
Table	Table.fullOuterJoin(Table right, Expression joinPredicate)	Joins two Tables.
Table	Table.intersect(Table right)	Intersects two Tables with duplicate records removed.
Table	Table.intersectAll(Table right)	Intersects two Tables.
Table	Table.join(Table right)	Joins two Tables.
Table	Table.join(Table right, Expression joinPredicate)	Joins two Tables.
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 Tables.
Table	Table.leftOuterJoin(Table right, Expression joinPredicate)	Joins two Tables.
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 Tables with duplicate records removed.
Table	Table.minusAll(Table right)	Minus of two Tables.
Table	Table.offset(int offset)	Limits a (possibly sorted) result from an offset position.
Table	Table.orderBy(Expression... fields)	Sorts the given Table.
Table	Model.predict(Table table, ColumnList inputColumns)	Performs prediction on the given table using specified input columns.
Table	Model.predict(Table table, ColumnList inputColumns, Map<String,String> options)	Performs prediction on the given table using specified input columns with runtime options.
Table	PartitionedTable.process(Class<? extends UserDefinedFunction> function, Object... arguments)	Transforms the given table by passing it into a process table function (PTF) with set semantics.
Table	PartitionedTable.process(String path, Object... arguments)	Transforms the given table by passing it into a process table function (PTF) with set semantics.
Table	Table.process(Class<? extends UserDefinedFunction> function, Object... arguments)	Transforms the given table by passing it into a process table function (PTF) with row semantics.
Table	Table.process(String path, Object... arguments)	Transforms the given table by passing it into a process table function (PTF) with row semantics.
Table	Table.renameColumns(Expression... fields)	Renames existing columns.
Table	Table.rightOuterJoin(Table right, Expression joinPredicate)	Joins two Tables.
Table	TableEnvironment.scan(String... tablePath)	Deprecated. use TableEnvironment.from(String)
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	Table.select(Expression... fields)	Performs a selection operation.
Table	WindowGroupedTable.select(Expression... fields)	Performs a selection operation on a window grouped 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.toChangelog(Expression... arguments)	Converts this dynamic table into an append-only table with an explicit operation code column using the built-in TO_CHANGELOG process table function.
Table	Table.union(Table right)	Unions two Tables with duplicate records removed.
Table	Table.unionAll(Table right)	Unions two Tables.
Table	Table.where(Expression predicate)	Filters out elements that don't pass the filter predicate.

Methods in org.apache.flink.table.api with parameters of type Table

Modifier and Type	Method	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.
void	TableEnvironment.createView(String path, Table view)	Registers a Table API object as a view similar to SQL views.
boolean	TableEnvironment.createView(String path, Table view, boolean ignoreIfExists)	Registers a Table API object as a view similar to SQL views.
Table	Table.fullOuterJoin(Table right, Expression joinPredicate)	Joins two Tables.
Table	Table.intersect(Table right)	Intersects two Tables with duplicate records removed.
Table	Table.intersectAll(Table right)	Intersects two Tables.
Table	Table.join(Table right)	Joins two Tables.
Table	Table.join(Table right, Expression joinPredicate)	Joins two Tables.
Table	Table.leftOuterJoin(Table right)	Joins two Tables.
Table	Table.leftOuterJoin(Table right, Expression joinPredicate)	Joins two Tables.
Table	Table.minus(Table right)	Minus of two Tables with duplicate records removed.
Table	Table.minusAll(Table right)	Minus of two Tables.
Table	Model.predict(Table table, ColumnList inputColumns)	Performs prediction on the given table using specified input columns.
Table	Model.predict(Table table, ColumnList inputColumns, Map<String,String> options)	Performs prediction on the given table using specified input columns with runtime options.
void	TableEnvironment.registerTable(String name, Table table)	Deprecated. use TableEnvironment.createTemporaryView(String, Table)
Table	Table.rightOuterJoin(Table right, Expression joinPredicate)	Joins two Tables.
Table	Table.union(Table right)	Unions two Tables with duplicate records removed.
Table	Table.unionAll(Table right)	Unions two Tables.

Uses of Table in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal with parameters of type Table

Modifier and Type	Method	Description
OutType	BaseExpressions.in(Table table)	Returns true if an expression exists in a given table sub-query.