org.apache.flink.table.api.bridge.java

接口 StreamStatementSet

所有超级接口:

org.apache.flink.table.api.StatementSet

所有已知实现类:

StreamStatementSetImpl

@PublicEvolving
public interface StreamStatementSet
extends org.apache.flink.table.api.StatementSet

A StatementSet that integrates with the Java-specific DataStream API.

It accepts pipelines defined by DML statements or Table objects. The planner can optimize all added statements together and then either submit them as one job or attach them to the underlying StreamExecutionEnvironment.

The added statements will be cleared when calling the StatementSet.execute() or attachAsDataStream() method.

方法概要

限定符和类型	方法和说明
StreamStatementSet	addInsert(String targetPath, org.apache.flink.table.api.Table table)
StreamStatementSet	addInsert(String targetPath, org.apache.flink.table.api.Table table, boolean overwrite)
StreamStatementSet	addInsert(org.apache.flink.table.api.TableDescriptor targetDescriptor, org.apache.flink.table.api.Table table)
StreamStatementSet	addInsert(org.apache.flink.table.api.TableDescriptor targetDescriptor, org.apache.flink.table.api.Table table, boolean overwrite)
StreamStatementSet	addInsertSql(String statement)
void	attachAsDataStream() Optimizes all statements as one entity and adds them as transformations to the underlying StreamExecutionEnvironment.

从接口继承的方法 org.apache.flink.table.api.StatementSet

execute, explain

方法详细资料

addInsertSql

StreamStatementSet addInsertSql(String statement)

指定者:

addInsertSql 在接口中 org.apache.flink.table.api.StatementSet

addInsert

StreamStatementSet addInsert(String targetPath,
                             org.apache.flink.table.api.Table table)

指定者:

addInsert 在接口中 org.apache.flink.table.api.StatementSet

addInsert

StreamStatementSet addInsert(String targetPath,
                             org.apache.flink.table.api.Table table,
                             boolean overwrite)

指定者:

addInsert 在接口中 org.apache.flink.table.api.StatementSet

addInsert

StreamStatementSet addInsert(org.apache.flink.table.api.TableDescriptor targetDescriptor,
                             org.apache.flink.table.api.Table table)

指定者:

addInsert 在接口中 org.apache.flink.table.api.StatementSet

addInsert

StreamStatementSet addInsert(org.apache.flink.table.api.TableDescriptor targetDescriptor,
                             org.apache.flink.table.api.Table table,
                             boolean overwrite)

指定者:

addInsert 在接口中 org.apache.flink.table.api.StatementSet

attachAsDataStream

void attachAsDataStream()

Optimizes all statements as one entity and adds them as transformations to the underlying StreamExecutionEnvironment.

Use StreamExecutionEnvironment.execute() to execute them.

The added statements will be cleared after calling this method.