from: sdks
to: runners
evidence:
 - file: "sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java"
   contains "import org.apache.beam.runners.core.construction.PTransformMatchers;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java"
   contains "import org.apache.beam.runners.core.metrics.LabeledMetrics;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchedStreamingWrite.java"
   contains "import org.apache.beam.runners.core.metrics.MetricsLogger;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubSubPayloadTranslation.java"
   contains "import org.apache.beam.runners.core.construction.PTransformTranslation;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionServer.java"
   contains "import org.apache.beam.runners.fnexecution.artifact.ArtifactRetrievalService;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java"
   contains "import org.apache.beam.runners.fnexecution.artifact.ArtifactRetrievalService;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/LatencyRecordingHttpRequestInitializer.java"
   contains "import org.apache.beam.runners.core.metrics.LabeledMetrics;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java"
   contains "import org.apache.beam.runners.direct.DirectOptions;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java"
   contains "import org.apache.beam.runners.dataflow.options.DataflowPipelineOptions;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/BeamSqlEnvRunner.java"
   contains "import org.apache.beam.runners.dataflow.options.DataflowPipelineOptions;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java"
   contains "import org.apache.beam.runners.core.GlobalCombineFnRunner;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java"
   contains "import org.apache.beam.runners.core.DoFnRunner;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/BeamFnDataReadRunner.java"
   contains "import org.apache.beam.runners.core.metrics.MonitoringInfoConstants;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java"
   contains "import org.apache.beam.runners.core.metrics.ExecutionStateSampler;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/CombineRunners.java"
   contains "import org.apache.beam.runners.core.construction.PTransformTranslation;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FlattenRunner.java"
   contains "import org.apache.beam.runners.core.construction.PTransformTranslation;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/ToStringFnRunner.java"
   contains "import org.apache.beam.runners.core.construction.PTransformTranslation;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/BeamFnDataWriteRunner.java"
   contains "import org.apache.beam.runners.core.construction.CoderTranslation;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/WindowMergingFnRunner.java"
   contains "import org.apache.beam.runners.core.construction.PTransformTranslation;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/WindowMappingFnRunner.java"
   contains "import org.apache.beam.runners.core.construction.PCollectionViewTranslation;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/MapFnRunners.java"
   contains "import org.apache.beam.runners.core.construction.RehydratedComponents;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/AssignWindowsRunner.java"
   contains "import org.apache.beam.runners.core.construction.PTransformTranslation;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/BeamFnStatusClient.java"
   contains "import org.apache.beam.runners.core.metrics.ExecutionStateTracker;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java"
   contains "import org.apache.beam.runners.core.SideInputReader;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateBackedIterable.java"
   contains "import static org.apache.beam.runners.core.construction.ModelCoders.STATE_BACKED_ITERABLE_CODER_URN;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PCollectionConsumerRegistry.java"
   contains "import org.apache.beam.runners.core.metrics.ExecutionStateTracker;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PTransformFunctionRegistry.java"
   contains "import org.apache.beam.runners.core.metrics.ExecutionStateTracker;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnTimerClient.java"
   contains "import org.apache.beam.runners.core.construction.Timer;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnTimerGrpcClient.java"
   contains "import org.apache.beam.runners.core.construction.Timer;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/BeamFnLoggingClient.java"
   contains "import org.apache.beam.runners.core.metrics.ExecutionStateTracker;"

from: sdks
to: runners
evidence:
 - file: "sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java"
   contains "import org.apache.beam.runners.core.metrics.ExecutionStateSampler;"