flink 92ad53e6a7e4c9df7055aac89b49ae95d50c5b4c

92ad53e6a7e4c9df7055aac89b49ae95d50c5b4c

Files Diff

Added: 5
Removed: 0
Renamed: 0
Modified: 12

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	2
	Change Parameter Type outputs : List<Tuple2<Output<StreamRecord<OUT>>,StreamEdge>> to outputs : List<? extends Tuple2<? extends Output<StreamRecord<OUT>>,StreamEdge>> in method public DirectedOutput(outputSelectors List<OutputSelector<OUT>>, outputs List<? extends Tuple2<? extends Output<StreamRecord<OUT>>,StreamEdge>>) in class org.apache.flink.streaming.api.collector.selector.DirectedOutput	From	To
	Change Parameter Type outputs : List<Tuple2<Output<StreamRecord<OUT>>,StreamEdge>> to outputs : List<? extends Tuple2<? extends Output<StreamRecord<OUT>>,StreamEdge>> in method public CopyingDirectedOutput(outputSelectors List<OutputSelector<OUT>>, outputs List<? extends Tuple2<? extends Output<StreamRecord<OUT>>,StreamEdge>>) in class org.apache.flink.streaming.api.collector.selector.CopyingDirectedOutput	From	To
	Rename Variable	1
	Rename Variable output : Output<StreamRecord<OUT>> to chainedOperatorOutput : WatermarkGaugeExposingOutput<StreamRecord<OUT>> in method private createChainedOperator(containingTask StreamTask<?,?>, operatorConfig StreamConfig, chainedConfigs Map<Integer,StreamConfig>, userCodeClassloader ClassLoader, streamOutputs Map<StreamEdge,RecordWriterOutput<?>>, allOperators List<StreamOperator<?>>, outputTag OutputTag<IN>) : WatermarkGaugeExposingOutput<StreamRecord<IN>> in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Change Return Type	3
	Change Return Type Output<StreamRecord<OUT>> to WatermarkGaugeExposingOutput<StreamRecord<OUT>> in method public getChainEntryPoint() : WatermarkGaugeExposingOutput<StreamRecord<OUT>> in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Change Return Type Output<StreamRecord<IN>> to WatermarkGaugeExposingOutput<StreamRecord<IN>> in method private createChainedOperator(containingTask StreamTask<?,?>, operatorConfig StreamConfig, chainedConfigs Map<Integer,StreamConfig>, userCodeClassloader ClassLoader, streamOutputs Map<StreamEdge,RecordWriterOutput<?>>, allOperators List<StreamOperator<?>>, outputTag OutputTag<IN>) : WatermarkGaugeExposingOutput<StreamRecord<IN>> in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Change Return Type Output<StreamRecord<T>> to WatermarkGaugeExposingOutput<StreamRecord<T>> in method private createOutputCollector(containingTask StreamTask<?,?>, operatorConfig StreamConfig, chainedConfigs Map<Integer,StreamConfig>, userCodeClassloader ClassLoader, streamOutputs Map<StreamEdge,RecordWriterOutput<?>>, allOperators List<StreamOperator<?>>) : WatermarkGaugeExposingOutput<StreamRecord<T>> in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Change Variable Type	5
	Change Variable Type output : Output to output : WatermarkGaugeExposingOutput<StreamRecord<OUT>> in method public OperatorChain(containingTask StreamTask<OUT,OP>) in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Change Variable Type output : Output<StreamRecord<OUT>> to chainedOperatorOutput : WatermarkGaugeExposingOutput<StreamRecord<OUT>> in method private createChainedOperator(containingTask StreamTask<?,?>, operatorConfig StreamConfig, chainedConfigs Map<Integer,StreamConfig>, userCodeClassloader ClassLoader, streamOutputs Map<StreamEdge,RecordWriterOutput<?>>, allOperators List<StreamOperator<?>>, outputTag OutputTag<IN>) : WatermarkGaugeExposingOutput<StreamRecord<IN>> in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Change Variable Type allOutputs : List<Tuple2<Output<StreamRecord<T>>,StreamEdge>> to allOutputs : List<Tuple2<WatermarkGaugeExposingOutput<StreamRecord<T>>,StreamEdge>> in method private createOutputCollector(containingTask StreamTask<?,?>, operatorConfig StreamConfig, chainedConfigs Map<Integer,StreamConfig>, userCodeClassloader ClassLoader, streamOutputs Map<StreamEdge,RecordWriterOutput<?>>, allOperators List<StreamOperator<?>>) : WatermarkGaugeExposingOutput<StreamRecord<T>> in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Change Variable Type output : Output<StreamRecord<T>> to output : WatermarkGaugeExposingOutput<StreamRecord<T>> in method private createOutputCollector(containingTask StreamTask<?,?>, operatorConfig StreamConfig, chainedConfigs Map<Integer,StreamConfig>, userCodeClassloader ClassLoader, streamOutputs Map<StreamEdge,RecordWriterOutput<?>>, allOperators List<StreamOperator<?>>) : WatermarkGaugeExposingOutput<StreamRecord<T>> in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Change Variable Type outputPair : Tuple2<Output<StreamRecord<OUT>>,StreamEdge> to outputPair : Tuple2<? extends Output<StreamRecord<OUT>>,StreamEdge> in method public DirectedOutput(outputSelectors List<OutputSelector<OUT>>, outputs List<? extends Tuple2<? extends Output<StreamRecord<OUT>>,StreamEdge>>) in class org.apache.flink.streaming.api.collector.selector.DirectedOutput	From	To
	Change Attribute Type	1
	Change Attribute Type chainEntryPoint : Output<StreamRecord<OUT>> to chainEntryPoint : WatermarkGaugeExposingOutput<StreamRecord<OUT>> in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To