Modifier and Type | Method and Description |
---|---|
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.
|
Table |
Transformer.transform(TableEnvironment tEnv,
Table input)
Applies the transformer on the input table, and returns the result table.
|
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 |
Pipeline.transform(TableEnvironment tEnv,
Table input)
Generate a result table by applying all the stages in this pipeline to the input table in
order.
|
Table |
Transformer.transform(TableEnvironment tEnv,
Table input)
Applies the transformer on the input table, and returns the result table.
|
Modifier and Type | Method and Description |
---|---|
static Table |
DataSetConversionUtil.toTable(Long sessionId,
DataSet<Row> data,
String[] colNames)
Convert the given DataSet into a Table with specified colNames.
|
static Table |
DataSetConversionUtil.toTable(Long sessionId,
DataSet<Row> data,
String[] colNames,
TypeInformation<?>[] colTypes)
Convert the given DataSet into a Table with specified colNames and colTypes.
|
static Table |
DataSetConversionUtil.toTable(Long sessionId,
DataSet<Row> data,
TableSchema schema)
Convert the given DataSet into a Table with specified TableSchema.
|
static Table |
DataStreamConversionUtil.toTable(Long sessionId,
DataStream<Row> data,
String[] colNames)
Convert the given DataStream to Table with specified colNames.
|
static Table |
DataStreamConversionUtil.toTable(Long sessionId,
DataStream<Row> data,
String[] colNames,
TypeInformation<?>[] colTypes)
Convert the given DataStream to Table with specified colNames and colTypes.
|
static Table |
DataStreamConversionUtil.toTable(Long sessionId,
DataStream<Row> data,
TableSchema schema)
Convert the given DataStream to Table with specified TableSchema.
|
static Table |
DataSetConversionUtil.toTable(MLEnvironment session,
DataSet<Row> data,
String[] colNames)
Convert the given DataSet into a Table with specified colNames.
|
static Table |
DataSetConversionUtil.toTable(MLEnvironment session,
DataSet<Row> data,
String[] colNames,
TypeInformation<?>[] colTypes)
Convert the given DataSet into a Table with specified colNames and colTypes.
|
static Table |
DataStreamConversionUtil.toTable(MLEnvironment session,
DataStream<Row> data,
String[] colNames)
Convert the given DataStream to Table with specified colNames.
|
static Table |
DataStreamConversionUtil.toTable(MLEnvironment session,
DataStream<Row> data,
String[] colNames,
TypeInformation<?>[] colTypes)
Convert the given DataStream to Table with specified colNames and colTypes.
|
Modifier and Type | Method and Description |
---|---|
static DataSet<Row> |
DataSetConversionUtil.fromTable(Long sessionId,
Table table)
|
static DataStream<Row> |
DataStreamConversionUtil.fromTable(Long sessionId,
Table table)
Convert the given Table to
DataStream <Row >. |
Modifier and Type | Method and Description |
---|---|
Table |
AlgoOperator.getOutput()
Returns the table held by operator.
|
Table[] |
AlgoOperator.getSideOutputs()
Returns the side outputs.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AlgoOperator.setOutput(Table output)
Set the table held by operator.
|
protected void |
AlgoOperator.setSideOutputs(Table[] sideOutputs)
Set the side outputs.
|
Modifier and Type | Method and Description |
---|---|
static BatchOperator<?> |
BatchOperator.fromTable(Table table)
create a new BatchOperator from table.
|
Constructor and Description |
---|
TableSourceBatchOp(Table table) |
Modifier and Type | Method and Description |
---|---|
static StreamOperator<?> |
StreamOperator.fromTable(Table table)
create a new StreamOperator from table.
|
Constructor and Description |
---|
TableSourceStreamOp(Table table) |
Modifier and Type | Field and Description |
---|---|
protected Table |
ModelBase.modelData |
Modifier and Type | Method and Description |
---|---|
Table |
ModelBase.getModelData()
Get model data as Table representation.
|
Table |
TransformerBase.transform(Table input)
Applies the transformer on the input table, and returns the result table.
|
Table |
TransformerBase.transform(TableEnvironment tEnv,
Table input) |
Modifier and Type | Method and Description |
---|---|
M |
EstimatorBase.fit(Table input)
|
M |
EstimatorBase.fit(TableEnvironment tEnv,
Table input) |
M |
ModelBase.setModelData(Table modelData)
Set the model data using the Table.
|
protected static TableEnvironment |
PipelineStageBase.tableEnvOf(Table table) |
Table |
TransformerBase.transform(Table input)
Applies the transformer on the input table, and returns the result table.
|
Table |
TransformerBase.transform(TableEnvironment tEnv,
Table input) |
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 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.
|
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 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 |
WindowGroupedTable.select(Expression... fields)
Performs a selection operation on a window grouped 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 |
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(String fields)
Deprecated.
|
Table |
WindowGroupedTable.select(String fields)
Deprecated.
|
Table |
GroupedTable.select(String fields)
Deprecated.
|
Table |
OverWindowedTable.select(String fields)
Deprecated.
|
Table |
FlatAggregateTable.select(String fields)
Deprecated.
|
Table |
AggregatedTable.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 |
---|---|
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet)
|
<T> Table |
BatchTableEnvironment.fromDataSet(DataSet<T> dataSet,
Expression... fields)
|
<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,
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. |
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
Class<T> clazz)
|
<T> DataSet<T> |
BatchTableEnvironment.toDataSet(Table table,
TypeInformation<T> typeInfo)
|
<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 |
---|---|
<T> Table |
StreamTableEnvironmentImpl.fromDataStream(DataStream<T> dataStream) |
<T> Table |
StreamTableEnvironmentImpl.fromDataStream(DataStream<T> dataStream,
Expression... fields) |
<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) |
<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–2021 The Apache Software Foundation. All rights reserved.