Package 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, org.apache.flink.table.api.Compilable, org.apache.flink.table.api.Executable, org.apache.flink.table.api.Explainable<org.apache.flink.table.api.StatementSet>, org.apache.flink.table.api.StatementSet

@Internal
public class StreamStatementSetImpl
extends org.apache.flink.table.api.internal.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	Description
protected	StreamStatementSetImpl(StreamTableEnvironmentImpl tableEnvironment)

Method Summary

Modifier and Type	Method	Description
StreamStatementSet	add(org.apache.flink.table.api.TablePipeline tablePipeline)
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.
StreamStatementSet	printExplain(org.apache.flink.table.api.ExplainDetail... extraDetails)

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.Explainable

explain, explain

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

compilePlan, execute

Constructor Detail

StreamStatementSetImpl

protected StreamStatementSetImpl(StreamTableEnvironmentImpl tableEnvironment)

Method Detail

add

public StreamStatementSet add(org.apache.flink.table.api.TablePipeline tablePipeline)

Specified by:

add in interface org.apache.flink.table.api.StatementSet

Specified by:

add in interface StreamStatementSet

Overrides:

add in class org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

addInsertSql

public StreamStatementSet addInsertSql(String statement)

Specified by:

addInsertSql in interface org.apache.flink.table.api.StatementSet

Specified by:

addInsertSql in interface StreamStatementSet

Overrides:

addInsertSql in class org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

addInsert

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

Specified by:

addInsert in interface org.apache.flink.table.api.StatementSet

Specified by:

addInsert in interface StreamStatementSet

Overrides:

addInsert in class org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

addInsert

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

Specified by:

addInsert in interface org.apache.flink.table.api.StatementSet

Specified by:

addInsert in interface StreamStatementSet

Overrides:

addInsert in class org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

addInsert

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

Specified by:

addInsert in interface org.apache.flink.table.api.StatementSet

Specified by:

addInsert in interface StreamStatementSet

Overrides:

addInsert in class org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

addInsert

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

Specified by:

addInsert in interface org.apache.flink.table.api.StatementSet

Specified by:

addInsert in interface StreamStatementSet

Overrides:

addInsert in class org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

printExplain

public StreamStatementSet printExplain(org.apache.flink.table.api.ExplainDetail... extraDetails)

Specified by:

printExplain in interface org.apache.flink.table.api.Explainable<org.apache.flink.table.api.StatementSet>

Specified by:

printExplain in interface StreamStatementSet

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