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" ] "[hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java]" -- "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieSparkUtils.scala]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerUtils.java]" -- "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieSparkUtils.scala]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerUtils.java]" -- "[hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[hudi-common/src/main/java/org/apache/hudi/common/util/ClusteringUtils.java]" -- "[hudi-common/src/main/java/org/apache/hudi/common/table/read/IncrementalQueryAnalyzer.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/RequestHandler.java]" -- "[hudi-common/src/main/java/org/apache/hudi/common/table/view/PriorityBasedFileSystemView.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieTimeline.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/ClusteringPlanActionExecutor.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/selector/StreamReadBucketIndexKeySelector.java]" -- "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/RestorePlanActionExecutor.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkTable.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieWriteHandle.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java]" -- "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/RowSource.java]" -- "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/AvroConversionUtils.scala]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java]" -- "[hudi-common/src/main/java/org/apache/hudi/common/table/read/IncrementalQueryAnalyzer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanner.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieWriteHandle.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/factory/HoodieSparkKeyGeneratorFactory.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/KeyGenUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/RestorePlanActionExecutor.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackActionExecutor.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadBucketIndexPartitioner.java]" -- "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadAppendPartitioner.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/BaseBootstrapMetadataHandler.java]" -- "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkCopyOnWriteTable.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-common/src/main/java/org/apache/hudi/exception/HoodieRecordCreationException.java]" -- "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/ExceptionWrappingIterator.scala]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/ErrorEvent.java]" -- "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieSparkUtils.scala]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieStreamerConfig.java]" -- "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/AvroConversionUtils.scala]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-common/src/main/java/org/apache/hudi/common/table/view/TableFileSystemView.java]" -- "[hudi-common/src/main/java/org/apache/hudi/common/table/view/RemoteHoodieTableFileSystemView.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkTable.java]" -- "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkCopyOnWriteTable.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/FileSliceHandler.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanner.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java]" -- "[hudi-common/src/main/java/org/apache/hudi/common/util/ClusteringUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/RestorePlanActionExecutor.java]" -- "[hudi-common/src/main/java/org/apache/hudi/common/table/read/IncrementalQueryAnalyzer.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/ExceptionWrappingIterator.scala]" -- "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieSparkUtils.scala]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java]" -- "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/HoodieJavaCopyOnWriteTable.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieStreamerConfig.java]" -- "[hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/AvroConversionUtils.scala]" -- "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieSparkUtils.scala]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-common/src/main/java/org/apache/hudi/common/table/view/PriorityBasedFileSystemView.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanner.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-common/src/main/java/org/apache/hudi/exception/HoodieRecordCreationException.java]" -- "[hudi-common/src/main/java/org/apache/hudi/exception/HoodieAvroSchemaException.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/ExceptionWrappingIterator.scala]" -- "[hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/factory/HoodieAvroKeyGeneratorFactory.java]" -- "[hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/SqlKeyGenerator.scala]" -- "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieDatasetBulkInsertHelper.scala]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/FileSliceHandler.java]" -- "[hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/RequestHandler.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/PreferWriterConflictResolutionStrategy.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/FileSliceHandler.java]" -- "[hudi-common/src/main/java/org/apache/hudi/common/table/view/TableFileSystemView.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala]" -- "[hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanActionExecutor.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/BaseJavaCommitActionExecutor.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkCopyOnWriteTable.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieDatasetBulkInsertHelper.scala]" -- "[hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackActionExecutor.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/PreferWriterConflictResolutionStrategy.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableConfig.java]" -- "[hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteWithLatestAvroPayload.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkTable.java]" -- "[hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/SqlKeyGenerator.scala]" -- "[hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/factory/HoodieSparkKeyGeneratorFactory.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SourceFormatAdapter.java]" -- "[hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieStreamerConfig.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; }