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

Class StreamStatementSetImpl

java.lang.Object

org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

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

All Implemented Interfaces:

StreamStatementSet, Compilable, Executable, Explainable<StatementSet>, StatementSet

@Internal
public class StreamStatementSetImpl
extends StatementSetImpl<StreamTableEnvironmentImpl>
implements StreamStatementSet

Implementation for StreamStatementSet.

Field Summary

Fields inherited from class org.apache.flink.table.api.internal.StatementSetImpl

operations, tableEnvironment

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StreamStatementSetImpl(StreamTableEnvironmentImpl tableEnvironment)

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 class org.apache.flink.table.api.internal.StatementSetImpl

compilePlan, execute, explain, getOperations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

compilePlan, execute

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

explain, explain

Constructor Detail

StreamStatementSetImpl

protected StreamStatementSetImpl(StreamTableEnvironmentImpl tableEnvironment)

Method Detail

add

public StreamStatementSet add(TablePipeline tablePipeline)

Description copied from interface: StatementSet

Adds a TablePipeline.

Specified by:

add in interface StreamStatementSet

Specified by:

add in interface StatementSet

Overrides:

add in class StatementSetImpl<StreamTableEnvironmentImpl>

addInsertSql

public StreamStatementSet addInsertSql(String statement)

Description copied from interface: StatementSet

Adds an INSERT INTO SQL statement.

Specified by:

addInsertSql in interface StreamStatementSet

Specified by:

addInsertSql in interface StatementSet

Overrides:

addInsertSql in class StatementSetImpl<StreamTableEnvironmentImpl>

addInsert

public StreamStatementSet addInsert(String targetPath,
                                    Table table)

Description copied from interface: StatementSet

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

Specified by:

addInsert in interface StreamStatementSet

Specified by:

addInsert in interface StatementSet

Overrides:

addInsert in class StatementSetImpl<StreamTableEnvironmentImpl>

See Also:

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

addInsert

public 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 StreamStatementSet

Specified by:

addInsert in interface StatementSet

Overrides:

addInsert in class StatementSetImpl<StreamTableEnvironmentImpl>

See Also:

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

addInsert

public StreamStatementSet addInsert(TableDescriptor targetDescriptor,
                                    Table table)

Description copied from interface: StatementSet

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

Specified by:

addInsert in interface StreamStatementSet

Specified by:

addInsert in interface StatementSet

Overrides:

addInsert in class StatementSetImpl<StreamTableEnvironmentImpl>

See Also:

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

addInsert

public 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 StreamStatementSet

Specified by:

addInsert in interface StatementSet

Overrides:

addInsert in class StatementSetImpl<StreamTableEnvironmentImpl>

See Also:

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

printExplain

public 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 StreamStatementSet

Specified by:

printExplain in interface Explainable<StatementSet>

attachAsDataStream

public void attachAsDataStream()

Description copied from interface: StreamStatementSet

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.

Specified by:

attachAsDataStream in interface StreamStatementSet