flink a612b9966f3ee020a5721ac2f039a3633c40146c

a612b9966f3ee020a5721ac2f039a3633c40146c

Files Diff

Added: 1
Removed: 2
Renamed: 0
Modified: 35

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Change Parameter Type	1
	Change Parameter Type timeProvider : TestTimeServiceProvider to timeProvider : TimeServiceProvider in method private setupSourceOperator(operator StreamSource<T,?>, timeChar TimeCharacteristic, watermarkInterval long, latencyMarkInterval long, timeProvider TimeServiceProvider) : void in class org.apache.flink.streaming.runtime.operators.StreamSourceOperatorTest	From	To
	Rename Variable	2
	Rename Variable recordOrWatermark : StreamElement to recordOrMark : StreamElement in method public processInput(streamOperator OneInputStreamOperator<IN,?>, lock Object) : boolean in class org.apache.flink.streaming.runtime.io.StreamInputProcessor	From	To
	Rename Variable enableTimestamps : boolean to enableMultiplexing : boolean in method public OperatorChain(containingTask StreamTask<OUT,OP>, reporter AccumulatorRegistry.Reporter) in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Extract Method	2
	Extract Method private sendToTarget(record T, targetChannel int) : void extracted from public broadcastEmit(record T) : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter	From	To
	Extract Method private sendToTarget(record T, targetChannel int) : void extracted from public emit(record T) : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter	From	To
	Rename Parameter	4
	Rename Parameter enableWatermarkMultiplexing : boolean to enableMultiplexing : boolean in method public StreamInputProcessor(inputGates InputGate[], inputSerializer TypeSerializer<IN>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, ioManager IOManager, enableMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.StreamInputProcessor	From	To
	Rename Parameter withTimestamps : boolean to enableMultiplexing : boolean in method private createStreamOutput(edge StreamEdge, upStreamConfig StreamConfig, outputIndex int, taskEnvironment Environment, enableMultiplexing boolean, reporter AccumulatorRegistry.Reporter, taskName String) : RecordWriterOutput<T> in class org.apache.flink.streaming.runtime.tasks.OperatorChain	From	To
	Rename Parameter enableWatermarkMultiplexing : boolean to enableMultiplexing : boolean in method public StreamTwoInputProcessor(inputGates1 Collection<InputGate>, inputGates2 Collection<InputGate>, inputSerializer1 TypeSerializer<IN1>, inputSerializer2 TypeSerializer<IN2>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, ioManager IOManager, enableMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor	From	To
	Rename Parameter enableWatermarkMultiplexing : boolean to enableMultiplexing : boolean in method public RecordWriterOutput(recordWriter StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>, outSerializer TypeSerializer<OUT>, enableMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.RecordWriterOutput	From	To