|
Change Parameter Type recordWriter : RecordWriter<SerializationDelegate> to recordWriter : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method public RecordWriterOutput(recordWriter RecordWriter<SerializationDelegate<StreamRecord<OUT>>>, outSerializer TypeSerializer<OUT>, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.RecordWriterOutput |
From |
To |
|
Change Parameter Type output : Collector<StreamRecord<?>> to output : Output<StreamRecord<?>> in method public addCollector(output Output<StreamRecord<?>>, edge StreamEdge) : void in class org.apache.flink.streaming.runtime.io.CollectorWrapper |
From |
To |
|
Change Parameter Type expected : Queue to expected : Queue<Object> in method public assertOutputEquals(message String, expected Queue<Object>, actual Queue<Object>) : void in class org.apache.flink.streaming.util.TestHarnessUtil |
From |
To |
|
Change Parameter Type operator : OneInputStreamOperator<?,T> to operator : OneInputStreamOperator<T,?> in method public ChainingOutput(operator OneInputStreamOperator<T,?>) in class org.apache.flink.streaming.runtime.tasks.OutputHandler.ChainingOutput |
From |
To |
|
Change Parameter Type operator : OneInputStreamOperator<?,T> to operator : OneInputStreamOperator<T,?> in method public CopyingChainingOutput(operator OneInputStreamOperator<T,?>, serializer TypeSerializer<StreamRecord<T>>) in class org.apache.flink.streaming.runtime.tasks.OutputHandler.CopyingChainingOutput |
From |
To |
|
Change Parameter Type actual : Queue to actual : Queue<Object> in method public assertOutputEquals(message String, expected Queue<Object>, actual Queue<Object>) : void in class org.apache.flink.streaming.util.TestHarnessUtil |
From |
To |
|
Change Parameter Type output : List to output : List<Object> in method public getStreamRecordsFromOutput(output List<Object>) : List<StreamRecord<OUT>> in class org.apache.flink.streaming.util.TestHarnessUtil |
From |
To |
|
Change Variable Type that : StreamRecord to that : StreamRecord<?> in method public equals(o Object) : boolean in class org.apache.flink.streaming.runtime.streamrecord.StreamRecord |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testOpenCloseAndTimestamps() : void in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testGroupedReduce() : void in class org.apache.flink.streaming.api.operators.StreamGroupedReduceTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testFlatMap() : void in class org.apache.flink.streaming.api.operators.StreamFlatMapTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testWatermarkForwarding() : void in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testFilter() : void in class org.apache.flink.streaming.api.operators.StreamFilterTest |
From |
To |
|
Change Variable Type checkpointerResults : Future[] to checkpointerResults : Future<Boolean>[] in method public testCheckpointing() : void in class org.apache.flink.streaming.runtime.tasks.SourceStreamTaskTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testWatermarkForwarding() : void in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTaskTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testMap() : void in class org.apache.flink.streaming.api.operators.StreamMapTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testCoFlatMap() : void in class org.apache.flink.streaming.api.operators.co.CoStreamFlatMapTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testCount() : void in class org.apache.flink.streaming.api.operators.StreamCounterTest |
From |
To |
|
Change Variable Type delegate : SerializationDelegate to delegate : SerializationDelegate<Object> in method private setupInputChannels() : void in class org.apache.flink.runtime.io.network.partition.consumer.StreamTestSingleInputGate |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testCoMap() : void in class org.apache.flink.streaming.api.operators.co.CoStreamMapTest |
From |
To |
|
Change Variable Type recordSerializer : RecordSerializer<SerializationDelegate<StreamRecord<T>>> to recordSerializer : RecordSerializer<SerializationDelegate<Object>> in method private setupInputChannels() : void in class org.apache.flink.runtime.io.network.partition.consumer.StreamTestSingleInputGate |
From |
To |
|
Change Variable Type outCollector : Collector<?> to output : Output<?> in method private createChainedCollector(chainedTaskConfig StreamConfig, accumulatorMap Map<String,Accumulator<?,?>>) : Output<StreamRecord<X>> in class org.apache.flink.streaming.runtime.tasks.OutputHandler |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testOpenCloseAndTimestamps() : void in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTaskTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testProject() : void in class org.apache.flink.streaming.api.operators.StreamProjectTest |
From |
To |
|
Change Variable Type expectedOutput : ConcurrentLinkedQueue to expectedOutput : ConcurrentLinkedQueue<Object> in method public testGroupedFold() : void in class org.apache.flink.streaming.api.operators.StreamGroupedFoldTest |
From |
To |
|
Change Attribute Type outputList : ConcurrentLinkedQueue to outputList : ConcurrentLinkedQueue<Object> in class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness |
From |
To |
|
Change Attribute Type currentRecordDeserializer : RecordDeserializer<DeserializationDelegate> to currentRecordDeserializer : RecordDeserializer<DeserializationDelegate<Object>> in class org.apache.flink.streaming.runtime.io.StreamInputProcessor |
From |
To |
|
Change Attribute Type deserializationDelegate2 : DeserializationDelegate to deserializationDelegate2 : DeserializationDelegate<Object> in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor |
From |
To |
|
Change Attribute Type outputList : ConcurrentLinkedQueue to outputList : ConcurrentLinkedQueue<Object> in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness |
From |
To |
|
Change Attribute Type recordDeserializers : RecordDeserializer[] to recordDeserializers : RecordDeserializer<DeserializationDelegate<Object>>[] in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor |
From |
To |
|
Change Attribute Type outputList : ConcurrentLinkedQueue to outputList : ConcurrentLinkedQueue<Object> in class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness |
From |
To |
|
Change Attribute Type recordDeserializers : RecordDeserializer<DeserializationDelegate>[] to recordDeserializers : RecordDeserializer<DeserializationDelegate<Object>>[] in class org.apache.flink.streaming.runtime.io.StreamInputProcessor |
From |
To |
|
Change Attribute Type operator : OneInputStreamOperator to operator : OneInputStreamOperator<T,?> in class org.apache.flink.streaming.runtime.tasks.OutputHandler.ChainingOutput |
From |
To |
|
Change Attribute Type currentRecordDeserializer : RecordDeserializer to currentRecordDeserializer : RecordDeserializer<DeserializationDelegate<Object>> in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor |
From |
To |
|
Change Attribute Type deserializationDelegate1 : DeserializationDelegate to deserializationDelegate1 : DeserializationDelegate<Object> in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor |
From |
To |
|
Change Attribute Type serializationDelegate : SerializationDelegate to serializationDelegate : SerializationDelegate<StreamRecord<OUT>> in class org.apache.flink.streaming.runtime.io.RecordWriterOutput |
From |
To |
|
Change Attribute Type deserializationDelegate : DeserializationDelegate to deserializationDelegate : DeserializationDelegate<Object> in class org.apache.flink.streaming.runtime.io.StreamInputProcessor |
From |
To |
|
Change Attribute Type recordWriter : RecordWriter<SerializationDelegate> to recordWriter : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in class org.apache.flink.streaming.runtime.io.RecordWriterOutput |
From |
To |