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

Interface StreamStatementSet

All Superinterfaces:

Compilable, Executable, Explainable<StatementSet>, StatementSet

All Known Implementing Classes:

StreamStatementSetImpl

@PublicEvolving
public interface StreamStatementSet
extends 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.

Method Summary

Modifier and Type	Method and Description
StreamStatementSet	add(TablePipeline tablePipeline) Adds a TablePipeline.
StreamStatementSet	addInsert(String targetPath, Table table) Shorthand for statementSet.add(table.insertInto(targetPath)).
StreamStatementSet	addInsert(String targetPath, Table table, boolean overwrite) Shorthand for statementSet.add(table.insertInto(targetPath, overwrite)).
StreamStatementSet	addInsert(TableDescriptor targetDescriptor, Table table) Shorthand for statementSet.add(table.insertInto(targetDescriptor)).
StreamStatementSet	addInsert(TableDescriptor targetDescriptor, Table table, boolean overwrite) Shorthand for statementSet.add(table.insertInto(targetDescriptor, overwrite)).
StreamStatementSet	addInsertSql(String statement) Adds an INSERT INTO SQL statement.
void	attachAsDataStream() Optimizes all statements as one entity and adds them as transformations to the underlying StreamExecutionEnvironment.
StreamStatementSet	printExplain(ExplainDetail... extraDetails) Like Explainable.explain(ExplainDetail...), but piping the result to System.out.

Methods inherited from interface org.apache.flink.table.api.StatementSet

compilePlan, execute

Methods inherited from interface org.apache.flink.table.api.Explainable

explain, explain

Method Detail

add

StreamStatementSet add(TablePipeline tablePipeline)

Description copied from interface: StatementSet

Adds a TablePipeline.

Specified by:

add in interface StatementSet

addInsertSql

StreamStatementSet addInsertSql(String statement)

Description copied from interface: StatementSet

Adds an INSERT INTO SQL statement.

Specified by:

addInsertSql in interface StatementSet

addInsert

StreamStatementSet addInsert(String targetPath,
                             Table table)

Description copied from interface: StatementSet

Shorthand for statementSet.add(table.insertInto(targetPath)).

Specified by:

addInsert in interface StatementSet

See Also:

StatementSet.add(TablePipeline), Table.insertInto(String)

addInsert

StreamStatementSet addInsert(String targetPath,
                             Table table,
                             boolean overwrite)

Description copied from interface: StatementSet

Shorthand for statementSet.add(table.insertInto(targetPath, overwrite)).

Specified by:

addInsert in interface StatementSet

See Also:

StatementSet.add(TablePipeline), Table.insertInto(String, boolean)

addInsert

StreamStatementSet addInsert(TableDescriptor targetDescriptor,
                             Table table)

Description copied from interface: StatementSet

Shorthand for statementSet.add(table.insertInto(targetDescriptor)).

Specified by:

addInsert in interface StatementSet

See Also:

StatementSet.add(TablePipeline), Table.insertInto(TableDescriptor)

addInsert

StreamStatementSet addInsert(TableDescriptor targetDescriptor,
                             Table table,
                             boolean overwrite)

Description copied from interface: StatementSet

Shorthand for statementSet.add(table.insertInto(targetDescriptor, overwrite)).

Specified by:

addInsert in interface StatementSet

See Also:

StatementSet.add(TablePipeline), Table.insertInto(TableDescriptor, boolean)

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.

printExplain

StreamStatementSet printExplain(ExplainDetail... extraDetails)

Description copied from interface: Explainable

Like Explainable.explain(ExplainDetail...), but piping the result to System.out.

Specified by:

printExplain in interface Explainable<StatementSet>