from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/CollectSink.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental/SocketStreamIterator.java" contains "import org.apache.flink.core.memory.DataInputViewStreamWrapper;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java" contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java" contains "import org.apache.flink.api.java.typeutils.PojoField;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/TypeInformationSerializationSchema.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/functions/StreamingFunctionUtils.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/util/keys/KeySelectorUtil.java" contains "import org.apache.flink.api.java.typeutils.ResultTypeQueryable;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/metrics/MinWatermarkGauge.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java" contains "import org.apache.flink.configuration.TaskManagerOptions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java" contains "import org.apache.flink.core.fs.FileSystemSafetyNet;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SystemProcessingTimeService.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TestProcessingTimeService.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationTail.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java" contains "import org.apache.flink.util.FlinkException;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ExceptionInChainedOperatorException.java" contains "import org.apache.flink.util.WrappingRuntimeException;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorEventDispatcherImpl.java" contains "import org.apache.flink.util.FlinkException;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTask.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamOperatorWrapper.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTask.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTaskActionExecutor.java" contains "import org.apache.flink.util.function.RunnableWithException;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeServiceImpl.java" contains "import org.apache.flink.util.concurrent.NeverCompleteFuture;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AbstractTwoInputStreamTask.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxExecutorImpl.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/Mail.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.java" contains "import org.apache.flink.util.ExceptionUtils;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamstatus/StatusWatermarkValve.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java" contains "import org.apache.flink.core.memory.DataInputViewStreamWrapper;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/TimestampsAndWatermarksOperator.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/util/AssignerWithPeriodicWatermarksAdapter.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/util/AssignerWithPunctuatedWatermarksAdapter.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/KeyMap.java" contains "import org.apache.flink.util.MathUtils;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/MergingWindowSet.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableProcessAllWindowFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueProcessAllWindowFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalAggregateProcessAllWindowFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueProcessWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalProcessAllWindowContext.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableProcessWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalAggregateProcessWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalIterableAllWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueAllWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalProcessWindowContext.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/KeyGroupStreamPartitioner.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/partitioner/CustomPartitionerWrapper.java" contains "import org.apache.flink.api.java.functions.KeySelector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/PushingAsyncDataInput.java" contains "import org.apache.flink.core.io.InputStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTwoInputProcessor.java" contains "import org.apache.flink.core.io.InputStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskSourceInput.java" contains "import org.apache.flink.core.io.InputStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessor.java" contains "import org.apache.flink.core.io.InputStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamInputProcessor.java" contains "import org.apache.flink.core.io.InputStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/MultipleInputSelectionHandler.java" contains "import org.apache.flink.core.io.InputStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java" contains "import org.apache.flink.core.io.InputStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamOneInputProcessor.java" contains "import org.apache.flink.core.io.InputStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java" contains "import static org.apache.flink.util.CloseableIterator.ofElement;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AbstractDataOutput.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierHandler.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordWriterOutput.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAligner.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamUtils.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/StreamProjection.java" contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AsyncDataStream.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java" contains "import org.apache.flink.api.java.typeutils.EnumTypeInfo;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastConnectedStream.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java" contains "import org.apache.flink.api.java.typeutils.InputTypeConfigurable;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/UnsupportedTimeCharacteristicException.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/QueryableStateStream.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/BroadcastStream.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java" contains "import org.apache.flink.api.common.operators.ResourceSpec;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java" contains "import org.apache.flink.api.common.operators.util.OperatorValidationUtils;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/ListCheckpointed.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/ExternallyInducedSource.java" contains "import org.apache.flink.util.FlinkException;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java" contains "import org.apache.flink.api.common.state.KeyedStateStore;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SinkTransformation.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/PartitionTransformation.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SideOutputTransformation.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/AbstractMultipleInputTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/LegacySourceTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/FeedbackTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/CoFeedbackTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SplitTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/MultipleInputTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/OneInputTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SourceTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/KeyedMultipleInputTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/TwoInputTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SelectTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/PhysicalTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/UnionTransformation.java" contains "import org.apache.flink.api.dag.Transformation;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleOperatorFactory.java" contains "import org.apache.flink.api.java.typeutils.InputTypeConfigurable;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimersSnapshotReaderWriters.java" contains "import org.apache.flink.api.java.typeutils.runtime.DataInputViewStream;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java" contains "import org.apache.flink.core.memory.DataOutputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceSerializationProxy.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedFold.java" contains "import org.apache.flink.core.memory.DataInputViewStreamWrapper;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleInputFormatOperatorFactory.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InputFormatOperatorFactory.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperatorFactory.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java" contains "import org.apache.flink.core.io.InputStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/BackendRestorerProcedure.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializer.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateHandler.java" contains "import org.apache.flink.core.fs.CloseableRegistry;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java" contains "import org.apache.flink.util.Disposable;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerServiceImpl.java" contains "import org.apache.flink.util.CloseableIterator;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/LegacyKeyedProcessOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleOutputFormatOperatorFactory.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractInput.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/CountingOutput.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimestampedCollector.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorStateContext.java" contains "import org.apache.flink.util.CloseableIterable;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/Output.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimersSnapshot.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/MailboxExecutor.java" contains "import org.apache.flink.util.FlinkRuntimeException;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerService.java" contains "import org.apache.flink.util.function.BiConsumerWithException;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OperatorSnapshotFutures.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamProject.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactoryUtil.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OutputTypeConfigurable.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactory.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializerSnapshot.java" contains "import org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedReduce.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/OutputFormatOperatorFactory.java" contains "import org.apache.flink.api.common.io.OutputFormat;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamMap.java" contains "import org.apache.flink.api.common.functions.MapFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFilter.java" contains "import org.apache.flink.api.common.functions.FilterFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/UdfStreamOperatorFactory.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SimpleUdfStreamOperatorFactory.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFlatMap.java" contains "import org.apache.flink.api.common.functions.FlatMapFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectCoordinationRequest.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectCoordinationResponse.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorCoordinator.java" contains "import org.apache.flink.core.memory.DataInputViewStreamWrapper;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultIterator.java" contains "import org.apache.flink.core.execution.JobClient;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java" contains "import org.apache.flink.core.execution.JobClient;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/AbstractCollectResultBuffer.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CheckpointedCollectResultBuffer.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/UncheckpointedCollectResultBuffer.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperatorFactory.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkOperator.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/util/SimpleVersionedListState.java" contains "import org.apache.flink.core.io.SimpleVersionedSerialization;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/KeyedCoProcessOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoBroadcastWithNonKeyedOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/LegacyKeyedCoProcessOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/CoProcessOperator.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/BatchTimestampsAndWatermarks.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/TimestampsAndWatermarksContext.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/StreamingTimestampsAndWatermarks.java" contains "import static org.apache.flink.util.Preconditions.checkState;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/SourceOutputWithWatermarks.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/WatermarkToDataOutput.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/source/TimestampsAndWatermarks.java" contains "import org.apache.flink.api.common.eventtime.TimestampAssigner;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/WatermarkQueueEntry.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/StreamRecordQueueEntry.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/OrderedStreamElementQueue.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/queue/UnorderedStreamElementQueue.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java" contains "import org.apache.flink.api.java.typeutils.MissingTypeInfo;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphUserHashHasher.java" contains "import org.apache.flink.util.StringUtils;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java" contains "import static org.apache.flink.util.StringUtils.byteToHexString;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java" contains "import static org.apache.flink.util.Preconditions.checkArgument;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/FunctionMasterCheckpointHookFactory.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/DirectedOutput.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/collector/selector/CopyingDirectedOutput.java" contains "import org.apache.flink.api.java.tuple.Tuple2;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java" contains "import org.apache.flink.api.java.typeutils.MissingTypeInfo;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java" contains "import org.apache.flink.configuration.ConfigUtils;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamPipelineOptions.java" contains "import org.apache.flink.configuration.ConfigOption;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java" contains "import org.apache.flink.configuration.ReadableConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/ExecutionCheckpointingOptions.java" contains "import org.apache.flink.configuration.CheckpointingOptions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/SumAggregator.java" contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/ComparableAggregator.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/aggregation/AggregationFunction.java" contains "import org.apache.flink.api.common.functions.ReduceFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/ProcessFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/KeyedProcessFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPeriodicWatermarks.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimestampAssigner.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedBroadcastProcessFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/CoProcessFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/ProcessJoinFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/KeyedCoProcessFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/CoFlatMapFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/BaseBroadcastProcessFunction.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/BroadcastProcessFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/RichCoMapFunction.java" contains "import org.apache.flink.api.common.functions.AbstractRichFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/RichCoFlatMapFunction.java" contains "import org.apache.flink.api.common.functions.AbstractRichFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/co/CoMapFunction.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java" contains "import org.apache.flink.api.java.typeutils.TypeExtractor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MultipleIdsMessageAcknowledgingSourceBase.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/InputFormatSourceFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromSplittableIteratorFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FromElementsFunction.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SerializedCheckpointData.java" contains "import org.apache.flink.core.memory.DataInputDeserializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedInputSplit.java" contains "import org.apache.flink.core.io.InputSplit;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileReadFunction.java" contains "import org.apache.flink.core.fs.FSDataInputStream;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java" contains "import org.apache.flink.core.fs.FileInputSplit;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/FileMonitoringFunction.java" contains "import org.apache.flink.core.fs.FileStatus;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java" contains "import org.apache.flink.util.IOUtils;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/StatefulSequenceSource.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperatorFactory.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichSourceFunction.java" contains "import org.apache.flink.api.common.functions.AbstractRichFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/RichParallelSourceFunction.java" contains "import org.apache.flink.api.common.functions.AbstractRichFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/RandomGenerator.java" contains "import org.apache.flink.api.common.functions.RuntimeContext;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/DataGenerator.java" contains "import org.apache.flink.api.common.functions.RuntimeContext;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java" contains "import org.apache.flink.types.Value;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/AsyncFunction.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/OutputFormatSinkFunction.java" contains "import org.apache.flink.api.java.typeutils.InputTypeConfigurable;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/PrintSinkFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/RichSinkFunction.java" contains "import org.apache.flink.api.common.functions.AbstractRichFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java" contains "import org.apache.flink.api.common.functions.Function;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/bucketassigners/BasePathBucketAssigner.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/bucketassigners/DateTimeBucketAssigner.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/bucketassigners/SimpleVersionedStringSerializer.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketStateSerializer.java" contains "import org.apache.flink.core.memory.DataInputDeserializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/OutputStreamBasedPartFileWriter.java" contains "import org.apache.flink.core.memory.DataInputDeserializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketAssigner.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/WriterProperties.java" contains "import org.apache.flink.core.io.SimpleVersionedSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Buckets.java" contains "import org.apache.flink.core.io.SimpleVersionedSerialization;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/RowWiseBucketWriter.java" contains "import org.apache.flink.core.fs.Path;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketWriter.java" contains "import org.apache.flink.core.fs.Path;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BulkBucketWriter.java" contains "import org.apache.flink.core.fs.Path;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java" contains "import org.apache.flink.core.fs.FileSystem;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketState.java" contains "import org.apache.flink.core.fs.Path;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketFactory.java" contains "import org.apache.flink.core.fs.Path;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/DefaultBucketFactoryImpl.java" contains "import org.apache.flink.core.fs.Path;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BulkPartWriter.java" contains "import org.apache.flink.core.fs.RecoverableFsDataOutputStream;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/RowWisePartWriter.java" contains "import org.apache.flink.core.fs.RecoverableFsDataOutputStream;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Bucket.java" contains "import org.apache.flink.core.fs.Path;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/OutputFileConfig.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSinkHelper.java" contains "import org.apache.flink.api.common.typeutils.base.LongSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/rollingpolicies/DefaultRollingPolicy.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ArrayFromTuple.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromTuple.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromTuple.java" contains "import org.apache.flink.api.java.tuple.Tuple;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessWindowFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessWindowFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessAllWindowFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessAllWindowFunction.java" contains "import org.apache.flink.configuration.Configuration;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/InternalProcessApplyWindowContext.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AllWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughAllWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/InternalProcessApplyAllWindowContext.java" contains "import org.apache.flink.util.OutputTag;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessAllWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/WindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyAllWindowFunction.java" contains "import org.apache.flink.util.Collector;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichWindowFunction.java" contains "import org.apache.flink.api.common.functions.AbstractRichFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichAllWindowFunction.java" contains "import org.apache.flink.api.common.functions.AbstractRichFunction;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/query/AbstractQueryableStateOperator.java" contains "import org.apache.flink.util.Preconditions;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/query/QueryableAppendingStateOperator.java" contains "import org.apache.flink.api.common.state.AppendingState;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/query/QueryableValueStateOperator.java" contains "import org.apache.flink.api.common.state.StateDescriptor;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/DeltaTrigger.java" contains "import org.apache.flink.api.common.typeutils.TypeSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ProcessingTimeoutTrigger.java" contains "import org.apache.flink.api.common.typeutils.base.LongSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousEventTimeTrigger.java" contains "import org.apache.flink.api.common.typeutils.base.LongSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/ContinuousProcessingTimeTrigger.java" contains "import org.apache.flink.api.common.typeutils.base.LongSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/CountTrigger.java" contains "import org.apache.flink.api.common.typeutils.base.LongSerializer;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/Trigger.java" contains "import org.apache.flink.api.common.state.MergingState;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/time/Time.java" contains "import static org.apache.flink.util.Preconditions.checkNotNull;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/WindowAssigner.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/GlobalWindows.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingEventTimeWindows.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingEventTimeWindows.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/EventTimeSessionWindows.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingProcessingTimeWindows.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/BaseAlignedWindowAssigner.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/ProcessingTimeSessionWindows.java" contains "import org.apache.flink.api.common.ExecutionConfig;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/evictors/Evictor.java" contains "import org.apache.flink.api.common.functions.RuntimeContext;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/GlobalWindow.java" contains "import org.apache.flink.core.memory.DataInputView;" from: flink-streaming-java to: flink-core evidence: - file: "flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/windows/TimeWindow.java" contains "import org.apache.flink.core.memory.DataInputView;"