|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<T>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<T> in class org.apache.flink.api.common.operators.base.BulkIterationBase |
From |
To |
|
Change Parameter Type mutables : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<OUT>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.compiler.util.NoOpUnaryUdfOp |
From |
To |
|
Change Parameter Type serializer : TypeSerializer<T> to typeInfo : TypeInformation<T> in method public AggregatingUdf(typeInfo TypeInformation<T>, aggFunctions AggregationFunction<Object>[], fieldPositions int[]) in class org.apache.flink.api.scala.operators.ScalaAggregateOperator.AggregatingUdf |
From |
To |
|
Change Parameter Type mutableObjectSafe : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(input1 List<IN1>, input2 List<IN2>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.CoGroupOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<T>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<T> in class org.apache.flink.api.common.operators.base.FilterOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected abstract executeOnCollections(inputData List<IN>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.SingleInputOperator |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.GroupReduceOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<IN> in class org.apache.flink.api.common.operators.base.PartitionOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.MapPartitionOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<T>, inputData2 List<T>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<T> in class org.apache.flink.api.common.operators.Union |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected abstract executeOnCollections(inputData1 List<IN1>, inputData2 List<IN2>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.DualInputOperator |
From |
To |
|
Change Parameter Type keyClass : Class<KEY> to keySerializer : TypeSerializer<KEY> in method public HadoopTupleUnwrappingIterator(keySerializer TypeSerializer<KEY>) in class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator |
From |
To |
|
Change Parameter Type mutables : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<OUT>, inputData2 List<OUT>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.compiler.util.NoOpBinaryUdfOp |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.MapOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<IN1>, inputData2 List<IN2>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.CrossOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<T>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<T> in class org.apache.flink.api.common.operators.base.ReduceOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.CollectorMapOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<ST>, inputData2 List<WT>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<ST> in class org.apache.flink.api.common.operators.base.DeltaIterationBase |
From |
To |
|
Change Parameter Type mutableObjectSafe : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<IN1>, inputData2 List<IN2>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.JoinOperatorBase |
From |
To |
|
Change Parameter Type mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(input List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.FlatMapOperatorBase |
From |
To |
|
Rename Variable mutableObjectSafe : boolean to objectReuseDisabled : boolean in method protected executeOnCollections(input1 List<IN1>, input2 List<IN2>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.CoGroupOperatorBase |
From |
To |
|
Rename Variable mutableObjectSafeMode : boolean to objectReuseDisabled : boolean in method protected executeOnCollections(inputData List<T>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<T> in class org.apache.flink.api.common.operators.base.ReduceOperatorBase |
From |
To |
|
Rename Variable mutableObjectSafeMode : boolean to objectReuseDisabled : boolean in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.GroupReduceOperatorBase |
From |
To |
|
Rename Variable mutableObjectSafe : boolean to objectReuseDisabled : boolean in method protected executeOnCollections(inputData1 List<IN1>, inputData2 List<IN2>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.JoinOperatorBase |
From |
To |
|
Rename Variable numKeyFields : int to numFields : int in method private readObject(in ObjectInputStream) : void in class org.apache.flink.api.java.typeutils.runtime.PojoSerializer |
From |
To |
|
Rename Parameter mutables : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<OUT>, inputData2 List<OUT>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.compiler.util.NoOpBinaryUdfOp |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.MapOperatorBase |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<IN1>, inputData2 List<IN2>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.CrossOperatorBase |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected abstract executeOnCollections(inputData List<IN>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.SingleInputOperator |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<T>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<T> in class org.apache.flink.api.common.operators.base.ReduceOperatorBase |
From |
To |
|
Rename Parameter clazz : Class<?> to type : Class<?> in method public registerKryoSerializer(type Class<?>, serializerClass Class<? extends Serializer<?>>) : void in class org.apache.flink.api.common.ExecutionConfig |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.MapPartitionOperatorBase |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected abstract executeOnCollections(inputData1 List<IN1>, inputData2 List<IN2>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.DualInputOperator |
From |
To |
|
Rename Parameter clazz : Class<?> to type : Class<?> in method public registerKryoSerializer(type Class<?>, serializer Serializer<?>) : void in class org.apache.flink.api.common.ExecutionConfig |
From |
To |
|
Rename Parameter mutableObjectSafe : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<IN1>, inputData2 List<IN2>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.JoinOperatorBase |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(input List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.FlatMapOperatorBase |
From |
To |
|
Rename Parameter keyClass : Class<KEY> to keySerializer : TypeSerializer<KEY> in method public HadoopTupleUnwrappingIterator(keySerializer TypeSerializer<KEY>) in class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<T>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<T> in class org.apache.flink.api.common.operators.base.BulkIterationBase |
From |
To |
|
Rename Parameter mutables : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<OUT>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.compiler.util.NoOpUnaryUdfOp |
From |
To |
|
Rename Parameter serializer : TypeSerializer<T> to typeInfo : TypeInformation<T> in method public AggregatingUdf(typeInfo TypeInformation<T>, aggFunctions AggregationFunction<Object>[], fieldPositions int[]) in class org.apache.flink.api.scala.operators.ScalaAggregateOperator.AggregatingUdf |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<T>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<T> in class org.apache.flink.api.common.operators.base.FilterOperatorBase |
From |
To |
|
Rename Parameter mutableObjectSafe : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(input1 List<IN1>, input2 List<IN2>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.CoGroupOperatorBase |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.CollectorMapOperatorBase |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, ctx RuntimeContext, executionConfig ExecutionConfig) : List<OUT> in class org.apache.flink.api.common.operators.base.GroupReduceOperatorBase |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData List<IN>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<IN> in class org.apache.flink.api.common.operators.base.PartitionOperatorBase |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<ST>, inputData2 List<WT>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<ST> in class org.apache.flink.api.common.operators.base.DeltaIterationBase |
From |
To |
|
Rename Parameter mutableObjectSafeMode : boolean to executionConfig : ExecutionConfig in method protected executeOnCollections(inputData1 List<T>, inputData2 List<T>, runtimeContext RuntimeContext, executionConfig ExecutionConfig) : List<T> in class org.apache.flink.api.common.operators.Union |
From |
To |