Interface CrossVersionSink<InputT>
- All Superinterfaces:
Serializable,org.apache.flink.api.connector.sink2.Sink<InputT>
- All Known Implementing Classes:
BigtableMutateRowsSink
@Internal
public interface CrossVersionSink<InputT>
extends org.apache.flink.api.connector.sink2.Sink<InputT>
The cross-version seam every sink in this module implements instead of
Sink directly.
Two variants of this interface exist under src/main/java-flink2 (this one, empty)
and src/main/java-flink1; the build selects one via the flink.compat Maven
property (default flink2). Flink 1.20 still declares the deprecated
createWriter(Sink.InitContext) abstract while Flink 2.x removed the type outright, so no
single source file can satisfy both compilers — the 1.20 variant carries a compile-only default
for it, and everything else in the module stays one copy. See the version policy in the root
AGENTS.md and issue #32.
-
Method Summary
Methods inherited from interface org.apache.flink.api.connector.sink2.Sink
createWriter