graph G { compound="true" rankdir="TB" bgcolor="white" fontname="Tahoma" node [ fixedsize="false" fontname="Tahoma" color="white" fillcolor="deepskyblue2" fontcolor="black" shape="box" style="filled" penwidth="1.0" ] edge [ fontname="Arial" color="#00688b" fontcolor="black" fontsize="12" arrowsize="0.5" penwidth="1.0" ] "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/ChangeStreamConstant.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java]" -- "[flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; }