from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ClientIds.java" contains "import org.apache.hudi.storage.StoragePath;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ViewStorageProperties.java" contains "import org.apache.hudi.storage.StoragePath;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java" contains "import org.apache.hudi.common.util.StringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/metrics/FlinkClusteringMetrics.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/metrics/FlinkCompactionMetrics.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io 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-io 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-io evidence: - file: "hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java" contains "import static org.apache.hudi.common.util.PartitionPathEncodeUtils.DEFAULT_PARTITION_PATH;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java" contains "import org.apache.hudi.common.util.StringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/FileIndex.java" contains "import org.apache.hudi.storage.StoragePath;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/ExpressionEvaluators.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/ExpressionPredicates.java" contains "import static org.apache.hudi.common.util.ValidationUtils.checkState;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PartitionPruners.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PrimaryKeyPruners.java" contains "import org.apache.hudi.common.util.StringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/stats/ColumnStatsIndices.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java" contains "import org.apache.hudi.common.util.HoodieRecordUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java" contains "import org.apache.hudi.common.util.CommitUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionCommitSink.java" contains "import org.apache.hudi.common.util.CompactionUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/FlinkCompactionConfig.java" contains "import org.apache.hudi.common.util.FileIOUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionPlanOperator.java" contains "import org.apache.hudi.common.util.CompactionUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/HoodieFlinkCompactor.java" contains "import org.apache.hudi.common.util.CompactionUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/strategy/CompactionPlanStrategies.java" contains "import org.apache.hudi.common.util.StringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/RowDataKeyGen.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/AutoRowDataKeyGen.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriterHelper.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java" contains "import org.apache.hudi.common.util.BaseFileUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/WriteProfiles.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/append/AppendWriteFunction.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java" contains "import org.apache.hudi.io.IOUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/HoodieFlinkClusteringJob.java" contains "import org.apache.hudi.common.util.ClusteringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringCommitSink.java" contains "import org.apache.hudi.common.util.ClusteringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java" contains "import org.apache.hudi.common.util.ClusteringUtils;" from: hudi-flink-datasource to: hudi-io 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.util.ClusteringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java" contains "import org.apache.hudi.storage.StoragePath;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMessage.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java" contains "import org.apache.hudi.common.util.ReflectionUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/PayloadCreation.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java" contains "import org.apache.hudi.common.util.StringUtils;" from: hudi-flink-datasource to: hudi-io 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-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/common/AbstractStreamWriteFunction.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/ConsistentBucketAssignFunction.java" contains "import org.apache.hudi.common.util.StringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunctionWithRateLimit.java" contains "import org.apache.hudi.common.util.RateLimiter;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/event/WriteMetadataEvent.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/SchemaRegistryProvider.java" contains "import static org.apache.hudi.common.util.ConfigUtils.OLD_SCHEMAPROVIDER_CONFIG_PREFIX;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/FilebasedSchemaProvider.java" contains "import static org.apache.hudi.common.util.ConfigUtils.OLD_SCHEMAPROVIDER_CONFIG_PREFIX;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java" contains "import org.apache.hudi.common.util.StringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/TableOptionProperties.java" contains "import org.apache.hudi.storage.StoragePath;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java" contains "import org.apache.hudi.common.util.ConfigUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalog.java" contains "import org.apache.hudi.common.util.CollectionUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HiveSchemaUtils.java" contains "import org.apache.hudi.common.util.StringUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalogUtil.java" contains "import org.apache.hudi.exception.HoodieCatalogException;" from: hudi-flink-datasource to: hudi-io 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-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FilePathUtils.java" contains "import org.apache.hudi.storage.StoragePath;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/InternalSchemaManager.java" contains "import org.apache.hudi.common.util.InternalSchemaCache;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FormatUtils.java" contains "import org.apache.hudi.common.util.DefaultSizeEstimator;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/RecordIterators.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/TypeConverters.java" contains "import org.apache.hudi.common.util.ValidationUtils;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/CastMap.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io 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-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cdc/CdcInputSplit.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cdc/CdcInputFormat.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadInputSplit.java" contains "import org.apache.hudi.common.util.Option;" from: hudi-flink-datasource to: hudi-io evidence: - file: "hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadInputFormat.java" contains "import org.apache.hudi.common.util.HoodieRecordUtils;"