Core batch stream load writer shared across Flink versions. + * + *
Version-specific modules should wrap this class (for example via DorisBatchWriterAdapter and
+ * implement the appropriate Flink sink interfaces there.
+ */
+public class DorisBatchWriter This is the core implementation that is shared across different Flink versions.
+ * Version-specific modules should wrap this class and implement the appropriate Flink sink
+ * interfaces there (for example via DorisWriterAdapter).
+ *
+ * @param This class adapts Flink 1.x's {@link Sink.InitContext} to the version-neutral core writer in
+ * the base module while implementing {@link DorisAbstractWriter} for use by the 1.x connector
+ * module.
+ */
+public class DorisWriterAdapter This class adapts Flink 2.x's {@link WriterInitContext} to the version-neutral core writer in
+ * the base module while implementing {@link DorisAbstractWriter} for use by the 2.x connector
+ * module.
+ */
+public class DorisWriterAdapter Because the table source requires a decoding format, we are discovering the format using the
+ * provided {@link FactoryUtil} for convenience.
+ */
+public final class DorisDynamicTableFactory
+ implements DynamicTableSourceFactory, DynamicTableSinkFactory {
+
+ @Override
+ public String factoryIdentifier() {
+ return IDENTIFIER; // used for matching to `connector = '...'`
+ }
+
+ @Override
+ public Set