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;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/util/src/org/apache/beam/learning/katas/util/Log.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Triggers/Early Triggers/Early Triggers/src/org/apache/beam/learning/katas/triggers/earlytriggers/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Triggers/Early Triggers/Early Triggers/src/org/apache/beam/learning/katas/triggers/earlytriggers/GenerateEvent.java"
   contains "import org.apache.beam.sdk.io.GenerateSequence;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/src/org/apache/beam/learning/katas/triggers/windowaccummode/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/src/org/apache/beam/learning/katas/triggers/windowaccummode/GenerateEvent.java"
   contains "import org.apache.beam.sdk.io.GenerateSequence;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/src/org/apache/beam/learning/katas/triggers/eventtimetriggers/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/src/org/apache/beam/learning/katas/triggers/eventtimetriggers/GenerateEvent.java"
   contains "import org.apache.beam.sdk.io.GenerateSequence;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Introduction/Hello Beam/Hello Beam/src/org/apache/beam/learning/katas/intro/hello/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/IO/Built-in IOs/Built-in IOs/src/org/apache/beam/learning/katas/io/builtinios/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/IO/TextIO/TextIO Read/src/org/apache/beam/learning/katas/io/textio/read/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Windowing/Fixed Time Window/Fixed Time Window/src/org/apache/beam/learning/katas/windowing/fixedwindow/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/src/org/apache/beam/learning/katas/windowing/addingtimestamp/withtimestamps/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Windowing/Adding Timestamp/ParDo/src/org/apache/beam/learning/katas/windowing/addingtimestamp/pardo/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Common Transforms/Aggregation/Mean/src/org/apache/beam/learning/katas/commontransforms/aggregation/mean/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Common Transforms/Aggregation/Count/src/org/apache/beam/learning/katas/commontransforms/aggregation/count/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Common Transforms/Aggregation/Max/src/org/apache/beam/learning/katas/commontransforms/aggregation/max/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Common Transforms/Aggregation/Sum/src/org/apache/beam/learning/katas/commontransforms/aggregation/sum/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Common Transforms/Aggregation/Min/src/org/apache/beam/learning/katas/commontransforms/aggregation/min/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Common Transforms/Filter/ParDo/src/org/apache/beam/learning/katas/commontransforms/filter/pardo/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Common Transforms/Filter/Filter/src/org/apache/beam/learning/katas/commontransforms/filter/filter/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Common Transforms/WithKeys/WithKeys/src/org/apache/beam/learning/katas/commontransforms/withkeys/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/src/org/apache/beam/learning/katas/coretransforms/dofnadditionalparams/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefnlambda/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Combine/BinaryCombineFn/src/org/apache/beam/learning/katas/coretransforms/combine/binarycombinefn/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Combine/Simple Function/src/org/apache/beam/learning/katas/coretransforms/combine/simple/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Combine/Combine PerKey/src/org/apache/beam/learning/katas/coretransforms/combine/combineperkey/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Combine/CombineFn/src/org/apache/beam/learning/katas/coretransforms/combine/combinefn/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Branching/Branching/src/org/apache/beam/learning/katas/coretransforms/branching/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Map/ParDo OneToMany/src/org/apache/beam/learning/katas/coretransforms/map/pardoonetomany/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Map/ParDo/src/org/apache/beam/learning/katas/coretransforms/map/pardo/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Map/MapElements/src/org/apache/beam/learning/katas/coretransforms/map/mapelements/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Map/FlatMapElements/src/org/apache/beam/learning/katas/coretransforms/map/flatmapelements/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Flatten/Flatten/src/org/apache/beam/learning/katas/coretransforms/flatten/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Side Output/Side Output/src/org/apache/beam/learning/katas/coretransforms/sideoutput/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Partition/Partition/src/org/apache/beam/learning/katas/coretransforms/partition/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Side Input/Side Input/src/org/apache/beam/learning/katas/coretransforms/sideinput/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/GroupByKey/GroupByKey/src/org/apache/beam/learning/katas/coretransforms/groupbykey/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/src/org/apache/beam/learning/katas/coretransforms/cogroupbykey/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/java/Core Transforms/Composite Transform/Composite Transform/src/org/apache/beam/learning/katas/coretransforms/composite/Task.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/introduction/hello_beam/hello_beam/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/io/textio/read/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/windowing/adding_timestamp/pardo/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/windowing/fixed_time_window/fixed_time_window/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/combine/combine_perkey/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/combine/simple_function/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/combine/combinefn/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/composite/composite/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/branching/branching/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/map/pardo_onetomany/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/map/pardo/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/map/pardo_struct/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/flatten/flatten/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/side_input/side_input/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/additional_outputs/additional_outputs/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/partition/partition/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/groupbykey/groupbykey/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/cogroupbykey/cogroupbykey/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/mean/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/count/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/max/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/sum/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/min/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/filter/pardo/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/filter/filter/cmd/main.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/introduction/hello_beam/hello_beam_test/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/introduction/hello_beam/hello_beam/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/io/textio/read/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/windowing/adding_timestamp/pardo/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/windowing/fixed_time_window/fixed_time_window/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/combine/simple_function/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/combine/combinefn/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/composite/composite/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/branching/branching/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/map/pardo_onetomany/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/side_input/side_input/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/additional_outputs/additional_outputs/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/core_transforms/cogroupbykey/cogroupbykey/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/mean/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/count/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/max/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/sum/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/aggregation/min/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/common_transforms/filter/filter/pkg/task/task.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/windowing/adding_timestamp/pardo/pkg/common/data.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: learning
to: sdks
evidence:
 - file: "learning/katas/go/windowing/fixed_time_window/fixed_time_window/pkg/common/input.go"
   contains "    "github.com/apache/beam/sdks/go/pkg/beam""

from: runners
to: sdks
evidence:
 - file: "runners/local-java/src/main/java/org/apache/beam/runners/local/StructuralKey.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/local-java/src/main/java/org/apache/beam/runners/local/Bundle.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/ServerFactory.java"
   contains "import org.apache.beam.sdk.fn.channel.SocketAddressFactory;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/ByteStringCoder.java"
   contains "import org.apache.beam.sdk.coders.AtomicCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/WireCoders.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire/LengthPrefixUnknownCoders.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/translation/PipelineTranslatorUtils.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/translation/BatchSideInputHandlerFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/status/WorkerStatusClient.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java"
   contains "import org.apache.beam.sdk.fn.stream.DataStreams;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/InMemoryBagUserStateFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/StaticRemoteEnvironmentFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/EmbeddedEnvironmentFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/ExternalEnvironmentFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/EnvironmentFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/ProcessEnvironmentFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/ArtifactStagingService.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/ArtifactRetrievalService.java"
   contains "import org.apache.beam.sdk.io.FileSystems;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/GrpcDataService.java"
   contains "import org.apache.beam.sdk.fn.stream.OutboundObserverFactory;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/FnDataService.java"
   contains "import org.apache.beam.sdk.fn.data.CloseableFnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/RemoteInputDestination.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleCheckpointHandlers.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SingleEnvironmentInstanceJobBundleFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClient.java"
   contains "import org.apache.beam.sdk.fn.stream.SynchronizedStreamObserver;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/RemoteOutputReceiver.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/TimerReceiverFactory.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/RemoteBundle.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/OutputReceiverFactory.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ProcessBundleDescriptors.java"
   contains "import org.apache.beam.sdk.fn.data.RemoteGrpcPortRead;"

from: runners
to: sdks
evidence:
 - file: "runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/metrics/JetMetricsContainer.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/metrics/CounterImpl.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/metrics/AbstractMetric.java"
   contains "import org.apache.beam.sdk.metrics.MetricName;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/metrics/DistributionImpl.java"
   contains "import org.apache.beam.sdk.metrics.Distribution;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/metrics/JetMetricResults.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/metrics/GaugeImpl.java"
   contains "import org.apache.beam.sdk.metrics.Gauge;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/FailedRunningPipelineResults.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/JetPipelineResult.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/JetPipelineOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/JetRunnerRegistrar.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/JetRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/JetTransformTranslators.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/DAGBuilder.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/JetTranslationContext.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/JetTransformTranslator.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/JetGraphVisitor.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/AbstractParDoP.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/ParDoP.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/BoundedSourceP.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/StatefulParDoP.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/UnboundedSourceP.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/ViewP.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/WindowGroupP.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/ImpulseP.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/AssignWindowP.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/jet/src/main/java/org/apache/beam/runners/jet/processors/FlattenP.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java"
   contains "import org.apache.beam.sdk.metrics.MetricName;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SplittableDoFnOperator.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItemCoder.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SdfByteBufferKeySelector.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/KvToByteBufferKeySelector.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WorkItemKeySelector.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/FlinkKeyUtils.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SingletonKeyedWorkItem.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/FlinkMetricContainer.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/ReaderInvocationUtil.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/DoFnRunnerWithMetricsUpdate.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkDetachedRunnerResult.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineRunner.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunnerResult.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPipelineTranslator.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/TestFlinkRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineOptions.java"
   contains "import org.apache.beam.sdk.options.ApplicationNameOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPipelineTranslator.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPortablePipelineTranslator.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTranslationContext.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunnerRegistrar.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java"
   contains "import org.apache.beam.sdk.options.PortablePipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTranslationContext.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPortablePipelineTranslator.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTransformTranslators.java"
   contains "import org.apache.beam.sdk.coders.CannotProvideCoderException;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/CreateStreamingFlinkView.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineTranslator.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/PipelineTranslationModeOptimizer.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkExecutionEnvironments.java"
   contains "import org.apache.beam.sdk.util.InstanceBuilder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkTransformOverrides.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SourceInputFormat.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/ImpulseInputFormat.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SourceInputSplit.java"
   contains "import org.apache.beam.sdk.io.Source;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapper.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/DedupingOperator.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/TestStreamSource.java"
   contains "import org.apache.beam.sdk.coders.CoderException;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/StreamingImpulseSource.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferedElements.java"
   contains "import org.apache.beam.sdk.coders.InstantCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferingDoFnRunner.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/package-info.java"
   contains "import org.apache.beam.buildtools.NonnullByDefault;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeInformation.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/KvKeySelector.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueComparator.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueSerializer.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/WindowedKvKeySelector.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueTypeInformation.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/LookupPipelineVisitor.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/CountingPipelineVisitor.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkStatefulDoFnFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/SortingFlinkCombineRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/HashingFlinkCombineRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/AbstractFlinkCombineRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkMergingNonShuffleReduceFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStagePruningFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkReduceFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkPartialReduceFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkMultiOutputPruningFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/SingleWindowFlinkCombineRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/SideInputInitializer.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkStreamingSideInputHandlerFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/ImpulseSourceFunction.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkNonMergingReduceFunction.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkAssignWindows.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkExplodeWindowsFunction.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkAssignContext.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkSideInputReader.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/extensions-java/metrics/src/main/java/org/apache/beam/runners/extensions/metrics/MetricsGraphiteSink.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/extensions-java/metrics/src/main/java/org/apache/beam/runners/extensions/metrics/MetricsHttpSink.java"
   contains "import org.apache.beam.sdk.metrics.MetricKey;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/OutputAndTimeBoundedSplittableProcessElementInvoker.java"
   contains "import org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/StatefulDoFnRunner.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/GlobalCombineFnRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/GlobalCombineFnRunners.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnContextFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryStateInternals.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/MergingActiveWindowSet.java"
   contains "import org.apache.beam.sdk.coders.MapCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/GroupByKeyViaGroupByKeyOnly.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/StateTag.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/TimerInternals.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/NonEmptyPanes.java"
   contains "import org.apache.beam.sdk.coders.VarLongCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/StateTags.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/KeyedWorkItemCoder.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/StateNamespaces.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/SystemReduceFn.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryMultimapSideInputView.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/KeyedWorkItems.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryTimerInternals.java"
   contains "import org.apache.beam.sdk.util.WindowTracing;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/SimplePushbackSideInputDoFnRunner.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/WatermarkHold.java"
   contains "import org.apache.beam.sdk.util.WindowTracing;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/PushbackSideInputDoFnRunner.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/KeyedWorkItem.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataUtils.java"
   contains "import org.apache.beam.sdk.util.WindowTracing;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/GroupAlsoByWindowViaWindowSetNewDoFn.java"
   contains "import org.apache.beam.sdk.util.SystemDoFnInternal;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/PaneInfoTracker.java"
   contains "import org.apache.beam.sdk.util.WindowTracing;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableProcessElementInvoker.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/ElementByteSizeObservable.java"
   contains "import org.apache.beam.sdk.util.common.ElementByteSizeObserver;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/PeekingReiterator.java"
   contains "import org.apache.beam.sdk.util.common.Reiterator;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/ReadyCheckingSideInputReader.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/NullSideInputReader.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/OutputWindowedValue.java"
   contains "import org.apache.beam.sdk.values.TupleTag;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputReader.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFn.java"
   contains "import org.apache.beam.sdk.values.WindowingStrategy;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/UnsupportedSideInputReader.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/WindowingInternals.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/MergingStateAccessor.java"
   contains "import org.apache.beam.sdk.state.State;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/StateTable.java"
   contains "import org.apache.beam.sdk.state.State;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/TestInMemoryStateInternals.java"
   contains "import org.apache.beam.sdk.state.State;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/StateInternals.java"
   contains "import org.apache.beam.sdk.state.State;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/StateAccessor.java"
   contains "import org.apache.beam.sdk.state.State;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/StateMerging.java"
   contains "import org.apache.beam.sdk.state.BagState;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/StepContext.java"
   contains "import org.apache.beam.sdk.transforms.DoFn.BundleFinalizer;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryBundleFinalizer.java"
   contains "import org.apache.beam.sdk.transforms.DoFn.BundleFinalizer;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/ActiveWindowSet.java"
   contains "import org.apache.beam.sdk.transforms.windowing.BoundedWindow;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/NonMergingActiveWindowSet.java"
   contains "import org.apache.beam.sdk.transforms.windowing.BoundedWindow;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/HistogramCell.java"
   contains "import org.apache.beam.sdk.metrics.MetricName;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/DistributionCell.java"
   contains "import org.apache.beam.sdk.metrics.Distribution;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/DefaultMetricResults.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java"
   contains "import org.apache.beam.sdk.metrics.MetricKey;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsPusher.java"
   contains "import org.apache.beam.sdk.metrics.MetricQueryResults;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/GaugeData.java"
   contains "import org.apache.beam.sdk.metrics.GaugeResult;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MonitoringInfoMetricName.java"
   contains "import org.apache.beam.sdk.metrics.MetricName;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/CounterCell.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/LabeledMetrics.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java"
   contains "import org.apache.beam.sdk.metrics.MetricKey;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/NoOpMetricsSink.java"
   contains "import org.apache.beam.sdk.metrics.MetricQueryResults;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java"
   contains "import org.apache.beam.sdk.metrics.Distribution;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/DistributionData.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/GaugeCell.java"
   contains "import org.apache.beam.sdk.metrics.Gauge;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MonitoringInfoEncodings.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsLogger.java"
   contains "import org.apache.beam.sdk.annotations.Experimental;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java"
   contains "import org.apache.beam.sdk.coders.VarLongCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java"
   contains "import org.apache.beam.sdk.coders.InstantCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineRunner.java"
   contains "import org.apache.beam.sdk.coders.BitSetCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java"
   contains "import org.apache.beam.sdk.state.TimeDomain;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterSynchronizedProcessingTimeStateMachine.java"
   contains "import org.apache.beam.sdk.state.TimeDomain;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachine.java"
   contains "import org.apache.beam.sdk.state.TimeDomain;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterProcessingTimeStateMachine.java"
   contains "import org.apache.beam.sdk.state.TimeDomain;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/DefaultTriggerStateMachine.java"
   contains "import org.apache.beam.sdk.state.TimeDomain;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ReshuffleTriggerStateMachine.java"
   contains "import org.apache.beam.sdk.transforms.Reshuffle;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/NeverStateMachine.java"
   contains "import org.apache.beam.sdk.transforms.GroupByKey;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.java"
   contains "import org.apache.beam.sdk.transforms.windowing.BoundedWindow;"

from: runners
to: sdks
evidence:
 - file: "runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachines.java"
   contains "import org.apache.beam.sdk.transforms.windowing.Trigger;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectTransformExecutor.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectMetrics.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectTestOptions.java"
   contains "import org.apache.beam.sdk.options.ApplicationNameOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluatorRegistry.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DisplayDataValidator.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/StatefulParDoEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRegistrar.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DoFnLifecycleManager.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/RootProviderRegistry.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/BoundedReadEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectOptions.java"
   contains "import org.apache.beam.sdk.options.ApplicationNameOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ReadEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectGroupByKey.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoMultiOverrideFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ImmutabilityEnforcementFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/SideInputContainer.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectWriteViewVisitor.java"
   contains "import org.apache.beam.sdk.coders.KvCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/CloningBundleFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupByKeyOnlyEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/CopyOnAccessInMemoryStateInternals.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadDeduplicator.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ImmutabilityCheckingBundleFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/MultiStepCombine.java"
   contains "import org.apache.beam.sdk.coders.CannotProvideCoderException;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ModelEnforcement.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectGraphVisitor.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/EvaluationContext.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectGraph.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/PipelineExecutor.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/RootInputProvider.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/KeyedPValueTrackingVisitor.java"
   contains "import org.apache.beam.sdk.Pipeline.PipelineVisitor;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/UncommittedBundle.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/QuiescenceDriver.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ImpulseEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ImmutableListBundleFactory.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ViewEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DoFnLifecycleManagerRemovingTransformEvaluator.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/WindowEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/PCollectionViewWriter.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/CommittedBundle.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/CreateViewNoopEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluator.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/FlattenEvaluatorFactory.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/AbstractModelEnforcement.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/PassthroughTransformEvaluator.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/StepTransformResult.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformResult.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/WriteWithShardingFactory.java"
   contains "import org.apache.beam.sdk.io.WriteFiles;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/SourceShard.java"
   contains "import org.apache.beam.sdk.io.BoundedSource;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/PCollectionViewWindow.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkCallbackExecutor.java"
   contains "import org.apache.beam.sdk.values.WindowingStrategy;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/EmptyInputProvider.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectGroupByKeyOverrideFactory.java"
   contains "import org.apache.beam.sdk.values.KV;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectGBKIntoKeyedWorkItemsOverrideFactory.java"
   contains "import org.apache.beam.sdk.values.KV;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/BundleFactory.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectTimerInternals.java"
   contains "import org.apache.beam.sdk.state.TimeDomain;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectExecutionContext.java"
   contains "import org.apache.beam.sdk.transforms.DoFn.BundleFinalizer;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/CompletionCallback.java"
   contains "import org.apache.beam.sdk.runners.AppliedPTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/StepAndKey.java"
   contains "import org.apache.beam.sdk.runners.AppliedPTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutorFactory.java"
   contains "import org.apache.beam.sdk.runners.AppliedPTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/CommittedResult.java"
   contains "import org.apache.beam.sdk.runners.AppliedPTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/direct-java/src/main/java/org/apache/beam/runners/direct/ModelEnforcementFactory.java"
   contains "import org.apache.beam.sdk.runners.AppliedPTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/FnWithMetricsWrapper.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/SamzaMetricsContainer.java"
   contains "import org.apache.beam.sdk.metrics.GaugeResult;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/DoFnRunnerWithMetrics.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineResult.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobServerDriver.java"
   contains "import org.apache.beam.sdk.options.PipelineOptionsFactory;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunnerRegistrar.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/TestSamzaRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobInvoker.java"
   contains "import org.apache.beam.sdk.options.PortablePipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPortablePipelineOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/util/SamzaCoders.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/util/SamzaPipelineTranslatorUtils.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPublishViewTranslator.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTestStreamTranslator.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ReadTranslator.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPublishViewTransformOverride.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SplittableParDoTranslators.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/GroupByKeyTranslator.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ParDoBoundMultiTranslator.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPipelineTranslator.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PViewToIdMapper.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TranslationContext.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PortableTranslationContext.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTestStreamSystemFactory.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaImpulseSystemFactory.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/WindowAssignTranslator.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/FlattenPCollectionsTranslator.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigContext.java"
   contains "import org.apache.beam.sdk.values.PValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPublishView.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ImpulseTranslator.java"
   contains "import org.apache.beam.sdk.values.PBegin;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformConfigGenerator.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TransformTranslator.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTransformOverrides.java"
   contains "import org.apache.beam.sdk.runners.PTransformOverride;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaDoFnRunners.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaDoFnInvokerRegistrar.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/GroupByKeyOp.java"
   contains "import org.apache.beam.sdk.options.PipelineOptionsFactory;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java"
   contains "import org.apache.beam.sdk.coders.BooleanCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedTimerData.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpEmitter.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/WindowAssignOp.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/Op.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpAdapter.java"
   contains "import org.apache.beam.sdk.util.UserCodeException;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnRunnerWithKeyedInternals.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KvToKeyedWorkItemOp.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SingletonKeyedWorkItem.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/BundleManager.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/FutureCollector.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaAssignContext.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpMessage.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedInternals.java"
   contains "import org.apache.beam.sdk.state.State;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/state/SamzaMapState.java"
   contains "import org.apache.beam.sdk.state.MapState;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/state/SamzaSetState.java"
   contains "import org.apache.beam.sdk.state.ReadableState;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/transforms/GroupWithoutRepartition.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/samza/src/main/java/org/apache/beam/runners/samza/transforms/UpdatingCombineFn.java"
   contains "import org.apache.beam.sdk.transforms.Combine;"

from: runners
to: sdks
evidence:
 - file: "runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableRunner.java"
   contains "import org.apache.beam.sdk.fn.channel.ManagedChannelFactory;"

from: runners
to: sdks
evidence:
 - file: "runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableMetrics.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/portability/java/src/main/java/org/apache/beam/runners/portability/JobServicePipelineResult.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/portability/java/src/main/java/org/apache/beam/runners/portability/ExternalWorkerService.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableRunnerRegistrar.java"
   contains "import org.apache.beam.sdk.PipelineRunner;"

from: runners
to: sdks
evidence:
 - file: "runners/portability/java/src/main/java/org/apache/beam/runners/portability/testing/TestPortablePipelineOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/portability/java/src/main/java/org/apache/beam/runners/portability/testing/TestUniversalRunner.java"
   contains "import org.apache.beam.sdk.options.Description;"

from: runners
to: sdks
evidence:
 - file: "runners/portability/java/src/main/java/org/apache/beam/runners/portability/testing/TestPortableRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowMapTaskExecutorFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowBatchWorkerHarness.java"
   contains "import org.apache.beam.sdk.fn.JvmInitializers;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/FnApiWindowMappingFn.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/FetchAndFilterStreamingSideInputsOperation.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchDataflowWorker.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/MetricsContainerRegistry.java"
   contains "import org.apache.beam.sdk.metrics.MetricsContainer;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingStepMetricsContainer.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowMetricsContainer.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java"
   contains "import org.apache.beam.sdk.metrics.MetricsContainer;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java"
   contains "import org.apache.beam.sdk.metrics.MetricsContainer;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DeltaCounterCell.java"
   contains "import org.apache.beam.sdk.metrics.Counter;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/MetricsToCounterUpdateConverter.java"
   contains "import org.apache.beam.sdk.metrics.MetricKey;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowSystemMetrics.java"
   contains "import org.apache.beam.sdk.metrics.MetricName;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java"
   contains "import org.apache.beam.sdk.metrics.MetricsContainer;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DeltaDistributionCell.java"
   contains "import org.apache.beam.sdk.metrics.Distribution;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionStateRegistry.java"
   contains "import org.apache.beam.sdk.metrics.MetricsContainer;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContext.java"
   contains "import org.apache.beam.sdk.metrics.MetricName;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/MetricsEnvironmentContextActivationObserverRegistration.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ParDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReaderFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSources.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SimpleParDoFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ToIsmRecordForMultimapDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSourceOperationExecutor.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingGroupAlsoByWindowReshuffleFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingGroupAlsoByWindowViaWindowSetFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupingShuffleReaderFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupingShuffleReaderWithFaultyBytesReadCounter.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartialGroupByKeyParDoFns.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ExperimentContext.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/CreateIsmShardKeyAndSortKeyDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ValuesDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartitioningShuffleReader.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SplittableProcessFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartitioningShuffleReaderFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SinkFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowsParDoFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ShuffleSink.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowFnRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSideInputReader.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillSink.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SourceOperationExecutorFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReifyTimestampAndWindowsParDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SimpleDoFnRunnerFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowParDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingPCollectionViewWriterDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupingShuffleReader.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReaderRegistry.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/UngroupedShuffleReaderFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/AvroByteReader.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/AvroByteSinkFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/AssignWindowsParDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PubsubReader.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DefaultParDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DoFnRunnerFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/UngroupedShuffleReader.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SinkRegistry.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindowingWindmillReader.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerPipelineOptionsFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/CombineValuesFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/UngroupedWindmillReader.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PubsubSink.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DoFnInstanceManagers.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSinkFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/AvroByteReaderFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ShuffleSinkFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowElementExecutionTracker.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PairWithConstantKeyDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/InMemoryReaderFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ConcatReader.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/UserParDoFnFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ConcatReaderFactory.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/InMemoryReader.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSink.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingGroupAlsoByWindowsDoFns.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/AvroByteSink.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingSideInputFetcher.java"
   contains "import org.apache.beam.sdk.coders.AtomicCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillKeyedWorkItem.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingPCollectionViewWriterParDoFn.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ByteStringCoder.java"
   contains "import org.apache.beam.sdk.coders.AtomicCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateInternals.java"
   contains "import org.apache.beam.sdk.coders.BooleanCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerInternals.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowPortabilityPCollectionView.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/RunnerHarnessCoderCloudObjectTranslatorRegistrar.java"
   contains "import org.apache.beam.sdk.coders.BigEndianIntegerCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingKeyedWorkItemSideInputDoFnRunner.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StateFetcher.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateReader.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeUngroupingParDoFn.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReader.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DoFnInstanceManager.java"
   contains "import org.apache.beam.sdk.util.DoFnInfo;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOutputCounter.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowProcessFnRunner.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkItemStatusClient.java"
   contains "import org.apache.beam.sdk.util.UserCodeException;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillReaderIteratorBase.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateCache.java"
   contains "import org.apache.beam.sdk.util.Weighted;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SdkHarnessRegistries.java"
   contains "import static org.apache.beam.sdk.util.Preconditions.checkArgumentNotNull;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingSideInputDoFnRunner.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/Weighers.java"
   contains "import org.apache.beam.sdk.util.Weighted;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ApplianceShuffleEntryReader.java"
   contains "import org.apache.beam.sdk.util.common.Reiterator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ContextActivationObserverRegistry.java"
   contains "import org.apache.beam.sdk.util.common.ReflectHelpers;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReaderCache.java"
   contains "import org.apache.beam.sdk.io.UnboundedSource;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowRunnerHarness.java"
   contains "import org.apache.beam.sdk.io.FileSystems;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SideInputTrackingIsmReader.java"
   contains "import org.apache.beam.sdk.io.fs.ResourceId;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PCollectionViewWindow.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/LazilyInitializedSideInputReader.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ContextActivationObserver.java"
   contains "import org.apache.beam.sdk.annotations.Experimental;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimeUtils.java"
   contains "import org.apache.beam.sdk.transforms.windowing.BoundedWindow;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowApiUtils.java"
   contains "import org.apache.beam.sdk.extensions.gcp.util.Transport;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java"
   contains "import org.apache.beam.sdk.extensions.gcp.util.Transport;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/options/StreamingDataflowWorkerOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/apiary/FixMultiOutputInfosOnParDoInstructions.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowViaOutputBufferFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowReshuffleFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowAndCombineFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowViaIteratorsFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/TimerOrElement.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowsDoFns.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/ScalableBloomFilter.java"
   contains "import org.apache.beam.sdk.coders.AtomicCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/ValueInEmptyWindows.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowFn.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/StreamingGroupAlsoByWindowFn.java"
   contains "import org.apache.beam.sdk.values.KV;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/ForwardingReiterator.java"
   contains "import org.apache.beam.sdk.util.common.Reiterator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/TaggedReiteratorList.java"
   contains "import org.apache.beam.sdk.util.common.Reiterator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/BatchingShuffleEntryReader.java"
   contains "import org.apache.beam.sdk.util.common.Reiterator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/ShuffleEntryReader.java"
   contains "import org.apache.beam.sdk.util.common.Reiterator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/KeyGroupedShuffleEntries.java"
   contains "import org.apache.beam.sdk.util.common.Reiterable;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/ProgressTrackingReiterator.java"
   contains "import org.apache.beam.sdk.util.common.Reiterator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingShuffleEntryIterator.java"
   contains "import org.apache.beam.sdk.util.common.ElementByteSizeObservableIterable;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingShuffleRangeTracker.java"
   contains "import org.apache.beam.sdk.io.range.RangeTracker;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CreateRegisterFnOperationFunction.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/RegisterNodeFunction.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CreateExecutableStageNodeFunction.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/MapTaskToNetworkFunction.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/Nodes.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/LengthPrefixUnknownCoders.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/InsertFetchAndFilterStreamingSideInputNodes.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/StreamObserverFactory.java"
   contains "import org.apache.beam.sdk.fn.stream.AdvancingPhaser;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/GrpcWindmillServer.java"
   contains "import org.apache.beam.sdk.options.PipelineOptionsFactory;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/stream/ServerStreamObserverFactory.java"
   contains "import org.apache.beam.sdk.fn.stream.AdvancingPhaser;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/data/RemoteGrpcPortWriteOperation.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/data/RemoteGrpcPortReadOperation.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/data/BeamFnDataGrpcService.java"
   contains "import org.apache.beam.sdk.fn.stream.OutboundObserverFactory;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/RegisterAndProcessBundleOperation.java"
   contains "import org.apache.beam.sdk.fn.IdGenerator;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/ProcessRemoteBundleOperation.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/BeamFnMapTaskExecutor.java"
   contains "import org.apache.beam.sdk.metrics.MetricKey;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/DataflowSideInputHandlerFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters/CounterBackedElementByteSizeObserver.java"
   contains "import org.apache.beam.sdk.util.common.ElementByteSizeObserver;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowMetrics.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineRegistrar.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java"
   contains "import static org.apache.beam.sdk.options.ExperimentalOptions.hasExperiment;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TestDataflowRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java"
   contains "import static org.apache.beam.sdk.options.ExperimentalOptions.hasExperiment;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/StreamingViewOverrides.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/PrimitiveParDoSingleFactory.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchViewOverrides.java"
   contains "import org.apache.beam.sdk.coders.BigEndianLongCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/GroupIntoBatchesOverride.java"
   contains "import org.apache.beam.sdk.coders.KvCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TransformTranslator.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPTransformMatchers.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunnerInfo.java"
   contains "import org.apache.beam.sdk.util.ReleaseInfo;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/ReshuffleOverrideFactory.java"
   contains "import org.apache.beam.sdk.util.IdentityWindowFn;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/ReadTranslator.java"
   contains "import org.apache.beam.sdk.io.Source;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/CreateDataflowView.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/RequiresStableInputParDoOverrides.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/SplittableParDoOverrides.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunnerHooks.java"
   contains "import org.apache.beam.sdk.annotations.Experimental;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TestDataflowPipelineOptions.java"
   contains "import org.apache.beam.sdk.testing.TestPipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerLoggingOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineDebugOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

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

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowProfilingOptions.java"
   contains "import org.apache.beam.sdk.options.Description;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.java"
   contains "import org.apache.beam.sdk.options.Description;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/CloudDebuggerOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowWorkerHarnessOptions.java"
   contains "import org.apache.beam.sdk.options.Description;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DefaultGcpRegionFactory.java"
   contains "import org.apache.beam.sdk.options.DefaultValueFactory;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/GcsStager.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RowCoderCloudObjectTranslator.java"
   contains "import org.apache.beam.sdk.coders.RowCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjects.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java"
   contains "import org.apache.beam.sdk.coders.AtomicCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CoderCloudObjectTranslatorRegistrar.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DefaultCoderCloudObjectTranslatorRegistrar.java"
   contains "import org.apache.beam.sdk.coders.BigDecimalCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/AvroCoderCloudObjectTranslator.java"
   contains "import org.apache.beam.sdk.coders.AvroCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/SerializableCoderCloudObjectTranslator.java"
   contains "import org.apache.beam.sdk.coders.SerializableCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java"
   contains "import org.apache.beam.sdk.PipelineResult.State;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/Structs.java"
   contains "import org.apache.beam.sdk.util.StringUtils;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java"
   contains "import org.apache.beam.sdk.util.FluentBackoff;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/SchemaCoderCloudObjectTranslator.java"
   contains "import org.apache.beam.sdk.util.SerializableUtils;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DataflowTransport.java"
   contains "import static org.apache.beam.sdk.extensions.gcp.util.Transport.getJsonFactory;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/CustomSources.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java"
   contains "import org.apache.beam.sdk.coders.AtomicCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/InMemoryJobService.java"
   contains "import org.apache.beam.sdk.fn.stream.SynchronizedStreamObserver;"

from: runners
to: sdks
evidence:
 - file: "runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/PortablePipelineJarCreator.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/PortablePipelineResult.java"
   contains "import org.apache.beam.sdk.PipelineResult;"

from: runners
to: sdks
evidence:
 - file: "runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobInvocation.java"
   contains "import org.apache.beam.sdk.PipelineResult;"

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

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/Twister2PipelineTranslator.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/BatchTransformTranslator.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/StreamTransformTranslator.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/Twister2BatchPipelineTranslator.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/streaming/ReadSourceTranslatorStream.java"
   contains "import org.apache.beam.sdk.values.PBegin;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/batch/GroupByKeyTranslatorBatch.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/batch/PCollectionViewTranslatorBatch.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/batch/ParDoMultiOutputTranslatorBatch.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/batch/FlattenTranslatorBatch.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/batch/ReadSourceTranslatorBatch.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/batch/ImpulseTranslatorBatch.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/batch/AssignWindowTranslatorBatch.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/DoFnFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/AssignWindowsFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/GroupByWindowFunction.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/MapToTupleFunction.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/ByteToWindowFunctionPrimitive.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/ByteToWindowFunction.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/OutputTagFilter.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/ImpulseSource.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/internal/SystemReduceFnBuffering.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2PipelineResult.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2PipelineOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2Runner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2TestRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2RunnerRegistrar.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2TranslationContext.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2PipelineExecutionEnvironment.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2BatchTranslationContext.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translation/wrappers/Twister2BoundedSource.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/translation/wrappers/Twister2EmptySource.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/utils/Twister2SideInputReader.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/utils/TranslationUtils.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/twister2/src/main/java/org/apache/beam/runners/twister2/utils/Twister2AssignContext.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/SparkBeamMetric.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/PipelineTranslator.java"
   contains "import org.apache.beam.sdk.options.StreamingOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TranslationContext.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/SparkTransformOverrides.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TransformTranslator.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/SideInputStorage.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/utils/CachedSideInputReader.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/streaming/DatasetSourceStreaming.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/streaming/PipelineTranslatorStreaming.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/streaming/ReadSourceTranslatorStreaming.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DoFnRunnerWithMetrics.java"
   contains "import org.apache.beam.sdk.metrics.MetricsContainer;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DatasetSourceBatch.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/GroupByKeyTranslatorBatch.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/CombinePerKeyTranslatorBatch.java"
   contains "import org.apache.beam.sdk.coders.CannotProvideCoderException;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DoFnFunction.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/AggregatorCombiner.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ImpulseTranslatorBatch.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/PipelineTranslatorBatch.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/CreatePCollectionViewTranslatorBatch.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ProcessContext.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/WindowAssignTranslatorBatch.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/FlattenTranslatorBatch.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ReadSourceTranslatorBatch.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ReshuffleTranslatorBatch.java"
   contains "import org.apache.beam.sdk.transforms.Reshuffle;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/SparkSideInputReader.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/GroupAlsoByWindowViaOutputBufferFn.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/MultiOutputCoder.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/CoderHelpers.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/RowHelpers.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/SideInputBroadcast.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/KVHelpers.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/WindowingHelpers.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/aggregators/NamedAggregators.java"
   contains "import org.apache.beam.sdk.transforms.Combine;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineResult.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingRunner.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingRunnerRegistrar.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineResult.java"
   contains "import org.apache.beam.sdk.metrics.MetricResults;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunner.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineRunner.java"
   contains "import org.apache.beam.sdk.metrics.MetricsEnvironment;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunnerDebugger.java"
   contains "import org.apache.beam.sdk.options.ExperimentalOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/TestSparkPipelineOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkContextOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkCommonPipelineOptions.java"
   contains "import org.apache.beam.sdk.options.ApplicationNameOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/TestSparkRunner.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunnerRegistrar.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPortableStreamingPipelineOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkJobInvoker.java"
   contains "import org.apache.beam.sdk.options.PortablePipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkJobServerDriver.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkNativePipelineVisitor.java"
   contains "import org.apache.beam.sdk.values.PInput;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/SparkTransformOverrides.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/SparkBeamMetric.java"
   contains "import org.apache.beam.sdk.metrics.DistributionResult;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/coders/CoderHelpers.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/coders/SparkRunnerKryoRegistrator.java"
   contains "import org.apache.beam.sdk.values.KV;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/util/SparkCompat.java"
   contains "import org.apache.beam.sdk.options.ApplicationNameOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/util/SparkSideInputReader.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputBroadcast.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/util/SideInputStorage.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/util/TimerUtils.java"
   contains "import org.apache.beam.sdk.values.WindowingStrategy;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/util/CachedSideInputReader.java"
   contains "import org.apache.beam.sdk.values.PCollectionView;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/util/SparkCommon.java"
   contains "import org.apache.beam.sdk.annotations.Internal;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/util/GlobalWatermarkHolder.java"
   contains "import org.apache.beam.sdk.transforms.windowing.BoundedWindow;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkExecutableStageFunction.java"
   contains "import org.apache.beam.sdk.fn.data.FnDataReceiver;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/DoFnRunnerWithMetrics.java"
   contains "import org.apache.beam.sdk.metrics.MetricsContainer;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkCombineFn.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkTranslationContext.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/Dataset.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkBatchPortablePipelineTranslator.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/MultiDoFnFunction.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkStreamingPortablePipelineTranslator.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/BoundedDataset.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/ValueAndCoderLazySerializable.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkPCollectionView.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java"
   contains "import org.apache.beam.sdk.coders.ByteArrayCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TranslationUtils.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/GroupNonMergingWindowsFunctions.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/GroupCombineFunctions.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkExecutableStageExtractionFunction.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkGroupAlsoByWindowViaOutputBufferFn.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/ReifyTimestampsAndWindowsFunction.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkAssignWindowFn.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkPipelineTranslator.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformEvaluator.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/StreamingTransformTranslator.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/UnboundedDataset.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/SparkRunnerStreamingContextFactory.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/WatermarkSyncedDStream.java"
   contains "import org.apache.beam.sdk.util.WindowedValue;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/NamedAggregators.java"
   contains "import org.apache.beam.sdk.transforms.Combine;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/io/SourceRDD.java"
   contains "import org.apache.beam.sdk.metrics.MetricsContainer;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/io/SparkUnboundedSource.java"
   contains "import org.apache.beam.sdk.metrics.Gauge;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/io/MicrobatchSource.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/io/CreateStream.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/io/SourceDStream.java"
   contains "import org.apache.beam.sdk.io.Source;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/io/EmptyCheckpointMark.java"
   contains "import org.apache.beam.sdk.io.UnboundedSource;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/io/ConsoleIO.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/StateSpecFunctions.java"
   contains "import org.apache.beam.sdk.metrics.MetricsContainer;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.java"
   contains "import org.apache.beam.sdk.metrics.MetricName;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkTimerInternals.java"
   contains "import org.apache.beam.sdk.state.TimeDomain;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDoNaiveBounded.java"
   contains "import org.apache.beam.sdk.fn.splittabledofn.RestrictionTrackers;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ForwardingPTransform.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDo.java"
   contains "import org.apache.beam.sdk.options.ExperimentalOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslation.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/UnboundedReadFromBoundedSource.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SdkComponents.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/Environments.java"
   contains "import org.apache.beam.sdk.options.PipelineOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ExternalTranslation.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslators.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java"
   contains "import org.apache.beam.sdk.coders.CannotProvideCoderException;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/External.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ParDoTranslation.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TestStreamTranslation.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ModelCoderRegistrar.java"
   contains "import org.apache.beam.sdk.coders.BooleanCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/AvroGenericCoderRegistrar.java"
   contains "import org.apache.beam.sdk.coders.AvroGenericCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/AvroGenericCoderTranslator.java"
   contains "import org.apache.beam.sdk.coders.AvroGenericCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/Timer.java"
   contains "import org.apache.beam.sdk.coders.BooleanCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RunnerPCollectionView.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionTranslation.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/EmptyFlattenAsCreateFactory.java"
   contains "import org.apache.beam.sdk.coders.VoidCoder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslator.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslatorRegistrar.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslation.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PrimitiveCreate.java"
   contains "import org.apache.beam.sdk.coders.Coder;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineTranslation.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/UnconsumedReads.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/DeduplicatedFlattenFactory.java"
   contains "import org.apache.beam.sdk.Pipeline;"

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

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java"
   contains "import org.apache.beam.sdk.util.SerializableUtils;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CreatePCollectionViewTranslation.java"
   contains "import org.apache.beam.sdk.util.SerializableUtils;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WriteFilesTranslation.java"
   contains "import org.apache.beam.sdk.util.SerializableUtils;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowingStrategyTranslation.java"
   contains "import org.apache.beam.sdk.util.SerializableUtils;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformReplacements.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TransformInputs.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

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

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/UnsupportedOverrideFactory.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReplacementOutputs.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SingleInputOutputOverrideFactory.java"
   contains "import org.apache.beam.sdk.values.PCollection;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TriggerTranslation.java"
   contains "import org.apache.beam.sdk.state.TimeDomain;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/GroupByKeyTranslation.java"
   contains "import org.apache.beam.sdk.transforms.GroupByKey;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ImpulseTranslation.java"
   contains "import org.apache.beam.sdk.transforms.Impulse;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TransformPayloadTranslatorRegistrar.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/GroupIntoBatchesTranslation.java"
   contains "import org.apache.beam.sdk.transforms.GroupIntoBatches;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReshuffleTranslation.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/FlattenTranslator.java"
   contains "import org.apache.beam.sdk.transforms.Flatten;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowIntoTranslation.java"
   contains "import org.apache.beam.sdk.transforms.PTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/DisplayDataTranslation.java"
   contains "import org.apache.beam.sdk.transforms.display.DisplayData;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ExecutableStageTranslation.java"
   contains "import org.apache.beam.sdk.runners.AppliedPTransform;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/renderer/PipelineDotRenderer.java"
   contains "import org.apache.beam.sdk.Pipeline;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/resources/PipelineResourcesOptions.java"
   contains "import org.apache.beam.sdk.options.Default;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/resources/PipelineResources.java"
   contains "import org.apache.beam.sdk.options.FileStagingOptions;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyPCollectionFusers.java"
   contains "import org.apache.beam.sdk.transforms.Flatten;"

from: runners
to: sdks
evidence:
 - file: "runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/ProtoOverrides.java"
   contains "import org.apache.beam.sdk.runners.PTransformOverride;"