from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java" contains "import org.apache.hudi.keygen.ComplexAvroKeyGenerator;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/CompactionUtil.java" contains "import org.apache.hudi.metadata.HoodieTableMetadata;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkWriteClients.java" contains "import org.apache.hudi.table.action.compact.CompactionTriggerStrategy;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ClusteringUtil.java" contains "import org.apache.hudi.index.HoodieIndex;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkTables.java" contains "import org.apache.hudi.client.FlinkTaskContextSupplier;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/adapter/Utils.java" contains "import org.apache.hudi.exception.HoodieNotSupportedException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/adapter/Utils.java" contains "import org.apache.hudi.exception.HoodieNotSupportedException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java" contains "import org.apache.hudi.config.HoodieIndexConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java" contains "import org.apache.hudi.config.HoodieCleanConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java" contains "import org.apache.hudi.common.table.log.InstantRange;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/FileIndex.java" contains "import org.apache.hudi.client.common.HoodieFlinkEngineContext;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadBucketIndexPartitioner.java" contains "import org.apache.hudi.index.bucket.BucketIdentifier;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PrimaryKeyPruners.java" contains "import org.apache.hudi.index.bucket.BucketIdentifier;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/stats/ColumnStatsIndices.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/CleanFunction.java" contains "import org.apache.hudi.client.HoodieFlinkWriteClient;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactOperator.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionCommitSink.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/HoodieFlinkCompactor.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/FlinkCompactionConfig.java" contains "import org.apache.hudi.common.model.HoodieCleaningPolicy;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java" contains "import org.apache.hudi.common.model.CompactionOperation;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanEvent.java" contains "import org.apache.hudi.common.model.CompactionOperation;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanSourceFunction.java" contains "import org.apache.hudi.common.model.CompactionOperation;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionCommitEvent.java" contains "import org.apache.hudi.client.WriteStatus;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/WriterHelpers.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriterHelper.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/RowDataKeyGen.java" contains "import org.apache.hudi.exception.HoodieKeyException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/AutoRowDataKeyGen.java" contains "import org.apache.hudi.common.model.HoodieRecord;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriteFunction.java" contains "import org.apache.hudi.common.model.WriteOperationType;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/IndexRecord.java" contains "import org.apache.hudi.common.model.HoodieAvroRecord;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/batch/BatchBootstrapOperator.java" contains "import org.apache.hudi.common.model.HoodieRecord;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigner.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssigners.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketIndexPartitioner.java" contains "import org.apache.hudi.common.model.HoodieKey;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/EmptyWriteProfile.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfile.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/DeltaWriteProfile.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfiles.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/append/AppendWriteFunction.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/HoodieFlinkClusteringJob.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringCommitSink.java" contains "import org.apache.hudi.exception.HoodieClusteringException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/FlinkClusteringConfig.java" contains "import org.apache.hudi.common.model.HoodieCleaningPolicy;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanSourceFunction.java" contains "import org.apache.hudi.common.model.ClusteringGroupInfo;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanEvent.java" contains "import org.apache.hudi.common.model.ClusteringGroupInfo;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java" contains "import org.apache.hudi.common.model.ClusteringGroupInfo;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringCommitEvent.java" contains "import org.apache.hudi.client.WriteStatus;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/update/strategy/FlinkConsistentBucketUpdateStrategy.java" contains "import org.apache.hudi.common.model.HoodieAvroRecord;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/TimelineBasedCkpMetadata.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadataFactory.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/TimeWait.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/PayloadCreation.java" contains "import org.apache.hudi.common.model.BaseAvroPayload;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/common/AbstractStreamWriteFunction.java" contains "import org.apache.hudi.client.HoodieFlinkWriteClient;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketBulkInsertWriterHelper.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/ConsistentBucketAssignFunction.java" contains "import org.apache.hudi.exception.HoodieLockException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/ConsistentBucketStreamWriteFunction.java" contains "import org.apache.hudi.common.model.HoodieFileGroupId;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java" contains "import org.apache.hudi.common.model.HoodieKey;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunction.java" contains "import org.apache.hudi.keygen.KeyGenerator;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunctions.java" contains "import org.apache.hudi.common.model.HoodieRecord;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunctionWithRateLimit.java" contains "import org.apache.hudi.common.model.HoodieRecord;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/event/WriteMetadataEvent.java" contains "import org.apache.hudi.client.WriteStatus;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/SchemaRegistryProvider.java" contains "import org.apache.hudi.exception.HoodieIOException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/FilebasedSchemaProvider.java" contains "import org.apache.hudi.exception.HoodieIOException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java" contains "import org.apache.hudi.common.model.HoodieAvroRecordMerger;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java" contains "import org.apache.hudi.common.model.HoodieRecord;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalogUtil.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java" contains "import org.apache.hudi.exception.HoodieCatalogException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalog.java" contains "import org.apache.hudi.exception.HoodieMetadataException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/TableOptionProperties.java" contains "import org.apache.hudi.exception.HoodieIOException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalogFactory.java" contains "import org.apache.hudi.exception.HoodieCatalogException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HiveSchemaUtils.java" contains "import org.apache.hudi.common.model.HoodieRecord;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FormatUtils.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/ParquetSplitRecordIterator.java" contains "import org.apache.hudi.exception.HoodieIOException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cdc/CdcInputFormat.java" contains "import org.apache.hudi.config.HoodieWriteConfig;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadInputFormat.java" contains "import org.apache.hudi.exception.HoodieException;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadInputSplit.java" contains "import org.apache.hudi.common.table.log.InstantRange;" from: hudi-flink-datasource to: hudi-client evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadTableState.java" contains "import org.apache.hudi.common.model.HoodieRecord;"