flink fa0a2cae8c688cc946cda2e30e68b71929ce50d0

fa0a2cae8c688cc946cda2e30e68b71929ce50d0

Files Diff

Added: 1
Removed: 0
Renamed: 0
Modified: 4

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Move Method	1
	Move Method private processBufferOrEvent(bufferOrEvent BufferOrEvent) : void from class org.apache.flink.streaming.runtime.io.StreamInputProcessor to private processBufferOrEvent(bufferOrEvent BufferOrEvent) : void from class org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput	From	To
	Move Attribute	5
	Move Attribute private isFinished : boolean from class org.apache.flink.streaming.runtime.io.StreamInputProcessor to private isFinished : boolean from class org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput	From	To
	Move Attribute private barrierHandler : CheckpointBarrierHandler from class org.apache.flink.streaming.runtime.io.StreamInputProcessor to private barrierHandler : CheckpointBarrierHandler from class org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput	From	To
	Move Attribute private recordDeserializers : RecordDeserializer<DeserializationDelegate<StreamElement>>[] from class org.apache.flink.streaming.runtime.io.StreamInputProcessor to private recordDeserializers : RecordDeserializer<DeserializationDelegate<StreamElement>>[] from class org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput	From	To
	Move Attribute private currentRecordDeserializer : RecordDeserializer<DeserializationDelegate<StreamElement>> from class org.apache.flink.streaming.runtime.io.StreamInputProcessor to private currentRecordDeserializer : RecordDeserializer<DeserializationDelegate<StreamElement>> from class org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput	From	To
	Move Attribute private deserializationDelegate : DeserializationDelegate<StreamElement> from class org.apache.flink.streaming.runtime.io.StreamInputProcessor to private deserializationDelegate : DeserializationDelegate<StreamElement> from class org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput	From	To
	Extract Class	1
	Extract Class org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput from class org.apache.flink.streaming.runtime.io.StreamInputProcessor	From	To
	Extract Method	2
	Extract Method private processElement(recordOrMark StreamElement, channel int) : void extracted from public processInput() : boolean in class org.apache.flink.streaming.runtime.io.StreamInputProcessor	From	To
	Extract Method private initializeNumRecordsIn() : void extracted from public processInput() : boolean in class org.apache.flink.streaming.runtime.io.StreamInputProcessor	From	To