类的使用
org.apache.flink.table.planner.plan.nodes.exec.spec.DynamicTableSinkSpec

使用DynamicTableSinkSpec的程序包

程序包	说明
org.apache.flink.table.planner.plan.nodes.exec.batch
org.apache.flink.table.planner.plan.nodes.exec.common
org.apache.flink.table.planner.plan.nodes.exec.stream

org.apache.flink.table.planner.plan.nodes.exec.batch中DynamicTableSinkSpec的使用

参数类型为DynamicTableSinkSpec的org.apache.flink.table.planner.plan.nodes.exec.batch中的构造器

构造器和说明
BatchExecSink(org.apache.flink.configuration.ReadableConfig tableConfig, DynamicTableSinkSpec tableSinkSpec, InputProperty inputProperty, org.apache.flink.table.types.logical.LogicalType outputType, String description)

org.apache.flink.table.planner.plan.nodes.exec.common中DynamicTableSinkSpec的使用

声明为DynamicTableSinkSpec的org.apache.flink.table.planner.plan.nodes.exec.common中的字段

限定符和类型	字段和说明
protected DynamicTableSinkSpec	CommonExecSink.tableSinkSpec

返回DynamicTableSinkSpec的org.apache.flink.table.planner.plan.nodes.exec.common中的方法

限定符和类型	方法和说明
DynamicTableSinkSpec	CommonExecSink.getTableSinkSpec()

参数类型为DynamicTableSinkSpec的org.apache.flink.table.planner.plan.nodes.exec.common中的构造器

构造器和说明
CommonExecSink(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, DynamicTableSinkSpec tableSinkSpec, org.apache.flink.table.connector.ChangelogMode inputChangelogMode, boolean isBounded, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.LogicalType outputType, String description)

org.apache.flink.table.planner.plan.nodes.exec.stream中DynamicTableSinkSpec的使用

参数类型为DynamicTableSinkSpec的org.apache.flink.table.planner.plan.nodes.exec.stream中的构造器

构造器和说明
StreamExecSink(int id, ExecNodeContext context, org.apache.flink.configuration.ReadableConfig persistedConfig, DynamicTableSinkSpec tableSinkSpec, org.apache.flink.table.connector.ChangelogMode inputChangelogMode, List<InputProperty> inputProperties, org.apache.flink.table.types.logical.LogicalType outputType, boolean upsertMaterialize, String description)
StreamExecSink(org.apache.flink.configuration.ReadableConfig tableConfig, DynamicTableSinkSpec tableSinkSpec, org.apache.flink.table.connector.ChangelogMode inputChangelogMode, InputProperty inputProperty, org.apache.flink.table.types.logical.LogicalType outputType, boolean upsertMaterialize, String description)