from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/DataSet.java"
   contains "import org.apache.flink.api.java.typeutils.InputTypeConfigurable;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/Utils.java"
   contains "import org.apache.flink.api.java.typeutils.GenericTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java"
   contains "import org.apache.flink.api.java.typeutils.PojoTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/LocalEnvironment.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironmentConfigUtils.java"
   contains "import org.apache.flink.configuration.ConfigUtils;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java"
   contains "import org.apache.flink.configuration.ConfigUtils;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/CollectionEnvironment.java"
   contains "import org.apache.flink.api.common.operators.CollectionExecutor;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/SemanticPropUtil.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMaxFunction.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/GroupReduceIterator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/FirstReducer.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/SampleInPartition.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/SampleInCoordinator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/SampleWithFraction.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/FlatMapIterator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/functions/FunctionAnnotation.java"
   contains "import org.apache.flink.api.common.InvalidProgramException;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/aggregation/SumAggregationFunction.java"
   contains "import org.apache.flink.types.ByteValue;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/aggregation/MinAggregationFunction.java"
   contains "import org.apache.flink.types.CopyableValue;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/aggregation/MaxAggregationFunction.java"
   contains "import org.apache.flink.types.CopyableValue;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/JoinOperator.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/ProjectOperator.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/CoGroupOperator.java"
   contains "import org.apache.flink.api.java.typeutils.TypeExtractor;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfoBase;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/SortedGrouping.java"
   contains "import org.apache.flink.api.java.typeutils.TypeExtractor;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/CrossOperator.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/KeyFunctions.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/DataSink.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/OperatorTranslation.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/UdfOperator.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputUdfOperator.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/DataSource.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/IterativeDataSet.java"
   contains "import org.apache.flink.types.Value;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/DeltaIteration.java"
   contains "import org.apache.flink.types.Value;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java"
   contains "import org.apache.flink.util.Preconditions;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/NoOpOperator.java"
   contains "import org.apache.flink.util.Preconditions;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputOperator.java"
   contains "import org.apache.flink.util.Preconditions;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/ReduceOperator.java"
   contains "import org.apache.flink.api.java.tuple.Tuple2;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/DistinctOperator.java"
   contains "import org.apache.flink.api.java.tuple.Tuple2;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/SortPartitionOperator.java"
   contains "import org.apache.flink.api.java.tuple.Tuple2;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/GroupCombineOperator.java"
   contains "import org.apache.flink.api.java.tuple.Tuple2;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java"
   contains "import org.apache.flink.api.java.tuple.Tuple2;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/CoGroupRawOperator.java"
   contains "import org.apache.flink.api.common.InvalidProgramException;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/Operator.java"
   contains "import org.apache.flink.api.common.ExecutionConfig;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/Grouping.java"
   contains "import org.apache.flink.api.common.InvalidProgramException;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/UnionOperator.java"
   contains "import org.apache.flink.api.common.InvalidProgramException;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/FlatMapOperator.java"
   contains "import org.apache.flink.api.common.operators.Operator;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/FilterOperator.java"
   contains "import org.apache.flink.api.common.operators.Operator;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/MapOperator.java"
   contains "import org.apache.flink.api.common.operators.Operator;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/DeltaIterationResultSet.java"
   contains "import org.apache.flink.api.common.operators.Keys;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/MapPartitionOperator.java"
   contains "import org.apache.flink.api.common.operators.Operator;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/SingleInputOperator.java"
   contains "import org.apache.flink.api.common.typeinfo.TypeInformation;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/BulkIterationResultSet.java"
   contains "import org.apache.flink.api.common.typeinfo.TypeInformation;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/join/JoinOperatorSetsBase.java"
   contains "import org.apache.flink.api.java.typeutils.TypeExtractor;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/join/JoinFunctionAssigner.java"
   contains "import org.apache.flink.api.common.functions.FlatJoinFunction;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/WrappingFunction.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/RichCombineToGroupCombineWrapper.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanUnwrappingReduceGroupOperator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanBothUnwrappingCoGroupOperator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/TupleUnwrappingJoiner.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/Tuple3UnwrappingIterator.java"
   contains "import org.apache.flink.util.TraversableOnceException;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanFilterOperator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanUnwrappingSortedReduceGroupOperator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanUnwrappingSortedGroupCombineOperator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/TupleWrappingCollector.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/CombineToGroupCombineWrapper.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/TupleRightUnwrappingJoiner.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/TupleUnwrappingIterator.java"
   contains "import org.apache.flink.util.TraversableOnceException;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/Tuple3WrappingCollector.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanLeftUnwrappingCoGroupOperator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanUnwrappingGroupCombineOperator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanRightUnwrappingCoGroupOperator.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/TupleLeftUnwrappingJoiner.java"
   contains "import org.apache.flink.util.Collector;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanUnwrappingReduceOperator.java"
   contains "import org.apache.flink.api.java.tuple.Tuple2;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/KeyRemovingMapper.java"
   contains "import org.apache.flink.api.java.tuple.Tuple2;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/PlanProjectOperator.java"
   contains "import org.apache.flink.api.java.tuple.Tuple;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/KeyExtractingMapper.java"
   contains "import org.apache.flink.api.java.tuple.Tuple2;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/operators/translation/TwoKeyExtractingMapper.java"
   contains "import org.apache.flink.api.java.tuple.Tuple3;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/RowCsvInputFormat.java"
   contains "import org.apache.flink.api.java.typeutils.ResultTypeQueryable;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/CsvOutputFormat.java"
   contains "import org.apache.flink.api.java.typeutils.InputTypeConfigurable;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/LocalCollectionOutputFormat.java"
   contains "import org.apache.flink.api.java.typeutils.InputTypeConfigurable;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/CsvReader.java"
   contains "import org.apache.flink.api.java.typeutils.PojoTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/TypeSerializerOutputFormat.java"
   contains "import org.apache.flink.api.java.typeutils.InputTypeConfigurable;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/PojoCsvInputFormat.java"
   contains "import org.apache.flink.api.java.typeutils.PojoTypeInfo;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/TypeSerializerInputFormat.java"
   contains "import org.apache.flink.api.java.typeutils.ResultTypeQueryable;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/TupleCsvInputFormat.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfoBase;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/BlockingShuffleOutputFormat.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/TextValueInputFormat.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/DiscardingOutputFormat.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/TextInputFormat.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/PrintingOutputFormat.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/PrimitiveInputFormat.java"
   contains "import org.apache.flink.types.parser.FieldParser;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java"
   contains "import org.apache.flink.types.parser.FieldParser;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/CollectionInputFormat.java"
   contains "import org.apache.flink.core.memory.DataInputViewStreamWrapper;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/ParallelIteratorInputFormat.java"
   contains "import org.apache.flink.core.io.GenericInputSplit;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/TextOutputFormat.java"
   contains "import org.apache.flink.core.fs.Path;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/SplitDataProperties.java"
   contains "import org.apache.flink.api.common.InvalidProgramException;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/io/IteratorInputFormat.java"
   contains "import org.apache.flink.api.common.io.GenericInputFormat;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/summarize/aggregation/SummaryAggregatorFactory.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfoBase;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/summarize/aggregation/ValueSummaryAggregator.java"
   contains "import org.apache.flink.types.BooleanValue;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/summarize/aggregation/TupleSummaryAggregator.java"
   contains "import org.apache.flink.api.java.tuple.Tuple;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/sampling/ReservoirSamplerWithoutReplacement.java"
   contains "import org.apache.flink.util.Preconditions;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/sampling/PoissonSampler.java"
   contains "import org.apache.flink.util.Preconditions;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/sampling/BernoulliSampler.java"
   contains "import org.apache.flink.util.Preconditions;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/sampling/ReservoirSamplerWithReplacement.java"
   contains "import org.apache.flink.util.Preconditions;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java"
   contains "import org.apache.flink.api.java.typeutils.TupleTypeInfoBase;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java"
   contains "import org.apache.flink.configuration.Configuration;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/utils/MultipleParameterTool.java"
   contains "import org.apache.flink.util.Preconditions;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/utils/PlanGenerator.java"
   contains "import org.apache.flink.util.Visitor;"

from: flink-java
to: flink-core
evidence:
 - file: "flink-java/src/main/java/org/apache/flink/api/java/utils/AbstractParameterTool.java"
   contains "import org.apache.flink.api.common.ExecutionConfig;"