Package org.apache.flink.table.api

Interface StatementSet

All Superinterfaces:

org.apache.flink.table.api.Compilable, Executable, Explainable<StatementSet>

@PublicEvolving
public interface StatementSet
extends Explainable<StatementSet>, org.apache.flink.table.api.Compilable, Executable

A StatementSet accepts pipelines defined by DML statements or Table objects. The planner can optimize all added statements together and then submit them as one job.

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

Method Summary

Modifier and Type	Method	Description
StatementSet	add(TablePipeline tablePipeline)	Adds a TablePipeline.
StatementSet	addInsert(String targetPath, Table table)	Shorthand for statementSet.add(table.insertInto(targetPath)).
StatementSet	addInsert(String targetPath, Table table, boolean overwrite)	Shorthand for statementSet.add(table.insertInto(targetPath, overwrite)).
StatementSet	addInsert(TableDescriptor targetDescriptor, Table table)	Shorthand for statementSet.add(table.insertInto(targetDescriptor)).
StatementSet	addInsert(TableDescriptor targetDescriptor, Table table, boolean overwrite)	Shorthand for statementSet.add(table.insertInto(targetDescriptor, overwrite)).
StatementSet	addInsertSql(String statement)	Adds an INSERT INTO SQL statement.
org.apache.flink.table.api.CompiledPlan	compilePlan()
TableResult	execute()	Executes this object.

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

explain, explain, printExplain

Method Details

add

StatementSet add(TablePipeline tablePipeline)

Adds a TablePipeline.

addInsertSql

StatementSet addInsertSql(String statement)

Adds an INSERT INTO SQL statement.

addInsert

StatementSet addInsert(String targetPath,
 Table table)

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

See Also:

• add(TablePipeline)
• Table.insertInto(String)

addInsert

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

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

See Also:

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

addInsert

StatementSet addInsert(TableDescriptor targetDescriptor,
 Table table)

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

See Also:

• add(TablePipeline)
• Table.insertInto(TableDescriptor)

addInsert

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

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

See Also:

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

execute

TableResult execute()

Executes this object.

By default, all DML operations are executed asynchronously. Use TableResult.await() or TableResult.getJobClient() to monitor the execution. Set TableConfigOptions.TABLE_DML_SYNC for always synchronous execution.

This method executes all statements as one job.

The added statements will be cleared after calling this method.

Specified by:

execute in interface Executable

compilePlan

@Experimental
org.apache.flink.table.api.CompiledPlan compilePlan()
                                             throws org.apache.flink.table.api.TableException

This method compiles all statements into a CompiledPlan that can be executed as one job.

Specified by:

compilePlan in interface org.apache.flink.table.api.Compilable

Throws:

org.apache.flink.table.api.TableException