org.apache.flink.streaming.api.connector.sink2

接口 WithPreCommitTopology<InputT,CommT>

所有超级接口:

Serializable, org.apache.flink.api.connector.sink2.Sink<InputT>, org.apache.flink.api.connector.sink2.SupportsCommitter<CommT>, SupportsPreCommitTopology<CommT,CommT>, org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<InputT,CommT>

已过时。

Please implement Sink, SupportsCommitter and SupportsPreCommitTopology instead.

@Experimental
 @Deprecated
public interface WithPreCommitTopology<InputT,CommT>
extends org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink<InputT,CommT>, SupportsPreCommitTopology<CommT,CommT>

Allows expert users to implement a custom topology after SinkWriter and before Committer.

It is recommended to use immutable committables because mutating committables can have unexpected side-effects.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink

org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT>

从接口继承的嵌套类/接口 org.apache.flink.api.connector.sink2.Sink

org.apache.flink.api.connector.sink2.Sink.InitContext, org.apache.flink.api.connector.sink2.Sink.InitContextWrapper

方法概要

限定符和类型	方法和说明
default org.apache.flink.core.io.SimpleVersionedSerializer<CommT>	getWriteResultSerializer() 已过时。 Defaults to SupportsCommitter.getCommittableSerializer() for backward compatibility.

从接口继承的方法 org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink

createCommitter, createCommitter

从接口继承的方法 org.apache.flink.api.connector.sink2.Sink

createWriter, createWriter

从接口继承的方法 org.apache.flink.api.connector.sink2.SupportsCommitter

getCommittableSerializer

从接口继承的方法 org.apache.flink.streaming.api.connector.sink2.SupportsPreCommitTopology

addPreCommitTopology

方法详细资料

getWriteResultSerializer

default org.apache.flink.core.io.SimpleVersionedSerializer<CommT> getWriteResultSerializer()

已过时。

Defaults to SupportsCommitter.getCommittableSerializer() for backward compatibility.

指定者:

getWriteResultSerializer 在接口中 SupportsPreCommitTopology<CommT,CommT>