from: client-spark
to: common
evidence:
 - file: "client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java"
   contains "import org.apache.celeborn.reflect.DynMethods;"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java"
   contains "import org.apache.celeborn.reflect.DynConstructors;"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java"
   contains "import org.apache.celeborn.reflect.DynMethods;"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java"
   contains "import org.apache.celeborn.common.util.Utils;"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java"
   contains "import org.apache.celeborn.common.util.Utils;"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java"
   contains "import org.apache.celeborn.common.util.Utils;"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java"
   contains "import org.apache.celeborn.common.util.Utils;"

from: client-spark
to: common
evidence:
 - file: "client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java"
   contains "import org.apache.celeborn.common.util.ThreadUtils;"

from: client-spark
to: common
evidence:
 - file: "client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala"
   contains "import org.apache.celeborn.common.identity.UserIdentifier"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala"
   contains "import org.apache.celeborn.common.identity.UserIdentifier"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala"
   contains "import org.apache.celeborn.common.CelebornConf"

from: client-spark
to: common
evidence:
 - file: "client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala"
   contains "import org.apache.celeborn.common.CelebornConf"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java"
   contains "import org.apache.celeborn.client.write.DataPusher;"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java"
   contains "import org.apache.celeborn.client.write.DataPusher;"

from: client-spark
to: client
evidence:
 - file: "client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java"
   contains "import org.apache.celeborn.client.write.PushTask;"

from: client-spark
to: client
evidence:
 - file: "client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java"
   contains "import org.apache.celeborn.client.write.DataPusher;"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java"
   contains "import org.apache.celeborn.client.ShuffleClient;"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java"
   contains "import org.apache.celeborn.client.LifecycleManager;"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java"
   contains "import org.apache.celeborn.client.ShuffleClient;"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java"
   contains "import org.apache.celeborn.client.LifecycleManager;"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala"
   contains "import org.apache.celeborn.client.LifecycleManager"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala"
   contains "import org.apache.celeborn.client.ShuffleClient"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala"
   contains "import org.apache.celeborn.client.LifecycleManager"

from: client-spark
to: client
evidence:
 - file: "client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala"
   contains "import org.apache.celeborn.client.ShuffleClient"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/MetaUtil.java"
   contains "import org.apache.celeborn.common.util.Utils;"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/IMetadataHandler.java"
   contains "import org.apache.celeborn.common.meta.DiskInfo;"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java"
   contains "import org.apache.celeborn.common.meta.AppDiskUsageMetric;"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java"
   contains "import org.apache.celeborn.common.util.ThreadUtils;"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java"
   contains "import org.apache.celeborn.common.util.ThreadUtils;"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAMasterMetaManager.java"
   contains "import org.apache.celeborn.common.meta.AppDiskUsageMetric;"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java"
   contains "import org.apache.celeborn.common.meta.DiskInfo;"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAHelper.java"
   contains "import org.apache.celeborn.common.client.MasterNotLeaderException;"

from: master
to: common
evidence:
 - file: "master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java"
   contains "import org.apache.celeborn.common.meta.DiskInfo;"

from: master
to: common
evidence:
 - file: "master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterNode.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: master
to: common
evidence:
 - file: "master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterClusterInfo.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: master
to: common
evidence:
 - file: "master/src/main/scala/org/apache/celeborn/service/deploy/master/network/CelebornRackResolver.scala"
   contains "import org.apache.celeborn.common.util.CelebornHadoopUtils"

from: master
to: common
evidence:
 - file: "master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala"
   contains "import org.apache.celeborn.common.metrics.MetricsSystem"

from: master
to: common
evidence:
 - file: "master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterSource.scala"
   contains "import org.apache.celeborn.common.metrics.MetricsSystem"

from: master
to: common
evidence:
 - file: "master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterArguments.scala"
   contains "import org.apache.celeborn.common.CelebornConf"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/LevelDBProvider.java"
   contains "import org.apache.celeborn.common.util.PbSerDeUtils;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/WorkingPartition.java"
   contains "import org.apache.celeborn.common.protocol.PartitionLocation;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java"
   contains "import org.apache.celeborn.reflect.DynMethods;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferDispatcher.java"
   contains "import org.apache.celeborn.common.network.util.NettyUtils;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java"
   contains "import org.apache.celeborn.common.util.*;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartition.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ChunkStreamManager.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionFileWriter.java"
   contains "import org.apache.celeborn.common.util.Utils;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartitionReader.java"
   contains "import org.apache.celeborn.common.util.ExceptionUtils;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManager.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileWriter.java"
   contains "import org.apache.celeborn.common.meta.DiskStatus;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ReducePartitionFileWriter.java"
   contains "import org.apache.celeborn.common.meta.FileInfo;"

from: worker
to: common
evidence:
 - file: "worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/CongestionController.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala"
   contains "import org.apache.celeborn.common.metrics.MetricsSystem"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala"
   contains "import org.apache.celeborn.common.metrics.MetricsSystem"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala"
   contains "import org.apache.celeborn.common.metrics.MetricsSystem"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala"
   contains "import org.apache.celeborn.common.metrics.source.Source"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/CommitInfo.scala"
   contains "import org.apache.celeborn.common.protocol.message.ControlMessages.CommitFilesResponse"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerArguments.scala"
   contains "import org.apache.celeborn.common.CelebornConf"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala"
   contains "import org.apache.celeborn.common.metrics.source.AbstractSource"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/ObservedDevice.scala"
   contains "import org.apache.celeborn.common.metrics.source.AbstractSource"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala"
   contains "import org.apache.celeborn.common.metrics.source.AbstractSource"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala"
   contains "import org.apache.celeborn.common.metrics.source.AbstractSource"

from: worker
to: common
evidence:
 - file: "worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceObserver.scala"
   contains "import org.apache.celeborn.common.meta.DiskStatus"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java"
   contains "import org.apache.celeborn.common.write.PushState;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/compress/Compressor.java"
   contains "import org.apache.celeborn.common.protocol.CompressionCodec;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/compress/Decompressor.java"
   contains "import org.apache.celeborn.common.protocol.CompressionCodec;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/listener/WorkersStatus.java"
   contains "import org.apache.celeborn.common.meta.WorkerInfo;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/ShuffleClient.java"
   contains "import org.apache.celeborn.common.write.PushState;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java"
   contains "import org.apache.celeborn.common.write.DataBatches;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/ReviveManager.java"
   contains "import org.apache.celeborn.common.util.ThreadUtils;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java"
   contains "import org.apache.celeborn.common.util.Utils;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java"
   contains "import org.apache.celeborn.common.util.ShuffleBlockInfoUtils;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java"
   contains "import org.apache.celeborn.common.util.ExceptionUtils;"

from: client
to: common
evidence:
 - file: "client/src/main/java/org/apache/celeborn/client/read/PartitionReader.java"
   contains "import org.apache.celeborn.common.protocol.PartitionLocation;"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala"
   contains "import org.apache.celeborn.common.util.FunctionConverter._"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala"
   contains "import org.apache.celeborn.common.util.JavaUtils"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala"
   contains "import org.apache.celeborn.common.util.FunctionConverter._"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/CommitManager.scala"
   contains "import org.apache.celeborn.common.util.FunctionConverter._"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala"
   contains "import org.apache.celeborn.common.util.FunctionConverter._"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/ApplicationHeartbeater.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/ShuffleClientHelper.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/RequestLocationCallContext.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: client
to: common
evidence:
 - file: "client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleTaskInfo.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java"
   contains "import org.apache.celeborn.common.network.util.NettyUtils;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceTracker.java"
   contains "import org.apache.celeborn.common.meta.ShufflePartitionLocationInfo;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java"
   contains "import org.apache.celeborn.common.protocol.PartitionLocation;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartitionFactory.java"
   contains "import org.apache.celeborn.common.protocol.CompressionCodec;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java"
   contains "import org.apache.celeborn.common.write.PushState;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java"
   contains "import org.apache.celeborn.common.network.util.NettyUtils;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java"
   contains "import org.apache.celeborn.common.util.JavaUtils;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java"
   contains "import org.apache.celeborn.common.network.util.FrameDecoder;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/MessageDecoderExt.java"
   contains "import org.apache.celeborn.common.network.protocol.*;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/ReadData.java"
   contains "import org.apache.celeborn.common.network.protocol.RequestMessage;"

from: client-flink
to: common
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/FlinkNettyManagedBuffer.java"
   contains "import org.apache.celeborn.common.network.buffer.ManagedBuffer;"

from: client-flink
to: client
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceTracker.java"
   contains "import org.apache.celeborn.client.listener.WorkerStatusListener;"

from: client-flink
to: client
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java"
   contains "import org.apache.celeborn.client.LifecycleManager;"

from: client-flink
to: client
evidence:
 - file: "client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java"
   contains "import org.apache.celeborn.client.ShuffleClientImpl;"

from: service
to: common
evidence:
 - file: "service/src/main/scala/org/apache/celeborn/server/common/Service.scala"
   contains "import org.apache.celeborn.common.metrics.MetricsSystem"

from: service
to: common
evidence:
 - file: "service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala"
   contains "import org.apache.celeborn.common.internal.Logging"

from: service
to: common
evidence:
 - file: "service/src/main/scala/org/apache/celeborn/server/common/http/HttpRequestHandler.scala"
   contains "import org.apache.celeborn.common.metrics.sink.PrometheusHttpRequestHandler"

from: service
to: common
evidence:
 - file: "service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala"
   contains "import org.apache.celeborn.common.internal.Logging"