|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.IterationTailOutput |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness.MockOutput |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.util.MockOutput |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.api.operators.AbstractStreamOperator.CountingOutput |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.util.CollectorOutput |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.runtime.tasks.OperatorChain.BroadcastingOutputCollector |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.api.collector.selector.DirectedOutput |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.runtime.tasks.OperatorChain.CopyingBroadcastingOutputCollector |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.runtime.tasks.OperatorChain.CopyingChainingOutput |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.api.operators.Output |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.runtime.io.RecordWriterOutput |
From |
To |
|
Change Parameter Type outputTag : OutputTag<?> to outputTag : OutputTag<X> in method public collect(outputTag OutputTag<X>, record StreamRecord<X>) : void in class org.apache.flink.streaming.runtime.tasks.OperatorChain.ChainingOutput |
From |
To |