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

类 StreamStatementSetImpl

java.lang.Object

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

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

所有已实现的接口:

StreamStatementSet, org.apache.flink.table.api.StatementSet

@Internal
public class StreamStatementSetImpl
extends org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>
implements StreamStatementSet

Implementation for StreamStatementSet.

字段概要

从类继承的字段 org.apache.flink.table.api.internal.StatementSetImpl

operations, tableEnvironment

构造器概要

构造器

限定符	构造器和说明
protected	StreamStatementSetImpl(StreamTableEnvironmentImpl tableEnvironment)

方法概要

限定符和类型	方法和说明
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.internal.StatementSetImpl

execute, explain, getJsonPlan

从类继承的方法 java.lang.Object

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

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

execute, explain

构造器详细资料

StreamStatementSetImpl

protected StreamStatementSetImpl(StreamTableEnvironmentImpl tableEnvironment)

方法详细资料

addInsertSql

public StreamStatementSet addInsertSql(String statement)

指定者:

addInsertSql 在接口中 StreamStatementSet

指定者:

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

覆盖:

addInsertSql 在类中 org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

addInsert

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

指定者:

addInsert 在接口中 StreamStatementSet

指定者:

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

覆盖:

addInsert 在类中 org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

addInsert

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

指定者:

addInsert 在接口中 StreamStatementSet

指定者:

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

覆盖:

addInsert 在类中 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)

指定者:

addInsert 在接口中 StreamStatementSet

指定者:

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

覆盖:

addInsert 在类中 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)

指定者:

addInsert 在接口中 StreamStatementSet

指定者:

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

覆盖:

addInsert 在类中 org.apache.flink.table.api.internal.StatementSetImpl<StreamTableEnvironmentImpl>

attachAsDataStream

public void attachAsDataStream()

从接口复制的说明: 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.

指定者:

attachAsDataStream 在接口中 StreamStatementSet