Uses of Class
org.apache.flink.cdc.connectors.maxcompute.options.MaxComputeWriteOptions
-
-
Uses of MaxComputeWriteOptions in org.apache.flink.cdc.connectors.maxcompute
Constructors in org.apache.flink.cdc.connectors.maxcompute with parameters of type MaxComputeWriteOptions Constructor Description MaxComputeDataSink(MaxComputeOptions options, MaxComputeWriteOptions writeOptions) -
Uses of MaxComputeWriteOptions in org.apache.flink.cdc.connectors.maxcompute.coordinator
Constructors in org.apache.flink.cdc.connectors.maxcompute.coordinator with parameters of type MaxComputeWriteOptions Constructor Description SessionManageCoordinatedOperatorFactory(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, String schemaOperatorUid)SessionManageCoordinatorProvider(String operatorName, org.apache.flink.runtime.jobgraph.OperatorID operatorID, MaxComputeOptions options, MaxComputeWriteOptions writeOptions) -
Uses of MaxComputeWriteOptions in org.apache.flink.cdc.connectors.maxcompute.options
Methods in org.apache.flink.cdc.connectors.maxcompute.options that return MaxComputeWriteOptions Modifier and Type Method Description MaxComputeWriteOptionsMaxComputeWriteOptions.Builder. build() -
Uses of MaxComputeWriteOptions in org.apache.flink.cdc.connectors.maxcompute.sink
Constructors in org.apache.flink.cdc.connectors.maxcompute.sink with parameters of type MaxComputeWriteOptions Constructor Description MaxComputeEventSink(MaxComputeOptions options, MaxComputeWriteOptions writeOptions)MaxComputeEventWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, org.apache.flink.api.connector.sink2.Sink.InitContext context)MaxComputeEventWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, org.apache.flink.api.connector.sink2.WriterInitContext context) -
Uses of MaxComputeWriteOptions in org.apache.flink.cdc.connectors.maxcompute.utils
Methods in org.apache.flink.cdc.connectors.maxcompute.utils with parameters of type MaxComputeWriteOptions Modifier and Type Method Description static com.aliyun.odps.tunnel.TableTunnelMaxComputeUtils. getTunnel(MaxComputeOptions maxComputeOptions, MaxComputeWriteOptions writeOptions) -
Uses of MaxComputeWriteOptions in org.apache.flink.cdc.connectors.maxcompute.writer
Methods in org.apache.flink.cdc.connectors.maxcompute.writer with parameters of type MaxComputeWriteOptions Modifier and Type Method Description static MaxComputeWriterMaxComputeWriter. batchWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)Constructors in org.apache.flink.cdc.connectors.maxcompute.writer with parameters of type MaxComputeWriteOptions Constructor Description BatchAppendWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)BatchUpsertWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)
-