b12d392e7c1e7e2baca995d475fa259efc6af246
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public createStreamRecordWriters(configuration StreamConfig, environment Environment) : List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>> renamed to public createRecordWriters(configuration StreamConfig, environment Environment) : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Rename Method private createStreamRecordWriter(edge StreamEdge, outputIndex int, environment Environment, taskName String, bufferTimeout long) : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> renamed to private createRecordWriter(edge StreamEdge, outputIndex int, environment Environment, taskName String, bufferTimeout long) : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Pull Up Method | 3 | ||
| Pull Up Method private checkErroneous() : void from class org.apache.flink.streaming.runtime.io.StreamRecordWriter to private checkErroneous() : void from class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
| Pull Up Method public close() : void from class org.apache.flink.streaming.runtime.io.StreamRecordWriter to public close() : void from class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
| Pull Up Method private notifyFlusherException(t Throwable) : void from class org.apache.flink.streaming.runtime.io.StreamRecordWriter to private notifyFlusherException(t Throwable) : void from class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
| Change Parameter Type | 4 | ||
| Change Parameter Type recordWriter : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> to recordWriter : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method public RecordWriterOutput(recordWriter RecordWriter<SerializationDelegate<StreamRecord<OUT>>>, outSerializer TypeSerializer<OUT>, outputTag OutputTag, streamStatusProvider StreamStatusProvider) in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
| Change Parameter Type streamRecordWriters : List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to recordWriters : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in method public OperatorChain(containingTask StreamTask<OUT,OP>, recordWriters List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>>) in class org.apache.flink.streaming.runtime.tasks.OperatorChain | From | To | |
| Change Parameter Type streamRecordWriter : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> to recordWriter : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method private createStreamOutput(recordWriter RecordWriter<SerializationDelegate<StreamRecord<OUT>>>, edge StreamEdge, upStreamConfig StreamConfig, taskEnvironment Environment) : RecordWriterOutput<OUT> in class org.apache.flink.streaming.runtime.tasks.OperatorChain | From | To | |
| Change Parameter Type recordWriter : StreamRecordWriter<LongValue> to recordWriter : RecordWriter<LongValue> in method public LongRecordWriterThread(recordWriter RecordWriter<LongValue>, broadcastMode boolean) in class org.apache.flink.streaming.runtime.io.benchmark.LongRecordWriterThread | From | To | |
| Rename Variable | 2 | ||
| Rename Variable streamRecordWriter : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> to recordWriter : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method private performCheckpoint(checkpointMetaData CheckpointMetaData, checkpointOptions CheckpointOptions, checkpointMetrics CheckpointMetrics) : boolean in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Rename Variable streamRecordWriters : List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to recordWriters : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in method public createRecordWriters(configuration StreamConfig, environment Environment) : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Pull Up Attribute | 2 | ||
| Pull Up Attribute private flusherException : Throwable from class org.apache.flink.streaming.runtime.io.StreamRecordWriter to private flusherException : Throwable from class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
| Pull Up Attribute private DEFAULT_OUTPUT_FLUSH_THREAD_NAME : String from class org.apache.flink.streaming.runtime.io.StreamRecordWriter to private DEFAULT_OUTPUT_FLUSH_THREAD_NAME : String from class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
| Change Return Type | 3 | ||
| Change Return Type StreamRecordWriter<T> to RecordWriter<T> in method public createRecordWriter(partitionIndex int, flushTimeout long) : RecordWriter<T> in class org.apache.flink.streaming.runtime.io.benchmark.StreamNetworkBenchmarkEnvironment | From | To | |
| Change Return Type List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in method public createRecordWriters(configuration StreamConfig, environment Environment) : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Return Type StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> to RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method private createRecordWriter(edge StreamEdge, outputIndex int, environment Environment, taskName String, bufferTimeout long) : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.streaming.runtime.io.StreamRecordWriter.OutputFlusher moved to org.apache.flink.runtime.io.network.api.writer.RecordWriter.OutputFlusher | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute streamRecordWriters : List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to recordWriters : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type output : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> to output : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method private createRecordWriter(edge StreamEdge, outputIndex int, environment Environment, taskName String, bufferTimeout long) : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Variable Type streamRecordWriter : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> to recordWriter : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method private performCheckpoint(checkpointMetaData CheckpointMetaData, checkpointOptions CheckpointOptions, checkpointMetrics CheckpointMetrics) : boolean in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Variable Type streamRecordWriters : List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to recordWriters : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in method public createRecordWriters(configuration StreamConfig, environment Environment) : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Attribute Type | 3 | ||
| Change Attribute Type recordWriter : StreamRecordWriter<LongValue> to recordWriter : RecordWriter<LongValue> in class org.apache.flink.streaming.runtime.io.benchmark.LongRecordWriterThread | From | To | |
| Change Attribute Type recordWriter : StreamRecordWriter<SerializationDelegate<StreamElement>> to recordWriter : RecordWriter<SerializationDelegate<StreamElement>> in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
| Change Attribute Type streamRecordWriters : List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to recordWriters : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter streamRecordWriters : List<StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>> to recordWriters : List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>> in method public OperatorChain(containingTask StreamTask<OUT,OP>, recordWriters List<RecordWriter<SerializationDelegate<StreamRecord<OUT>>>>) in class org.apache.flink.streaming.runtime.tasks.OperatorChain | From | To | |
| Rename Parameter streamRecordWriter : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> to recordWriter : RecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method private createStreamOutput(recordWriter RecordWriter<SerializationDelegate<StreamRecord<OUT>>>, edge StreamEdge, upStreamConfig StreamConfig, taskEnvironment Environment) : RecordWriterOutput<OUT> in class org.apache.flink.streaming.runtime.tasks.OperatorChain | From | To |