f7b113d965fd30db993cac99b63194dcd7869ad4
Files Diff
- Added: 5
- Removed: 1
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 2 | ||
| Rename Variable producerId : String to inputComponentId1 : String in method private createOutput(boltId String, bolt IRichBolt, inputStreams Map<GlobalStreamId,DataStream<Tuple>>) : SingleOutputStreamOperator<?,?> in class org.apache.flink.storm.api.FlinkTopology | From | To | |
| Rename Variable inputStreamId : String to inputStreamId1 : String in method private createOutput(boltId String, bolt IRichBolt, inputStreams Map<GlobalStreamId,DataStream<Tuple>>) : SingleOutputStreamOperator<?,?> in class org.apache.flink.storm.api.FlinkTopology | From | To | |
| Inline Method | 1 | ||
| Inline Method private createOutput(boltId String, bolt IRichBolt, streamId GlobalStreamId, inputStream DataStream<Tuple>) : SingleOutputStreamOperator<?,?> inlined to private translateTopology() : void in class org.apache.flink.storm.api.FlinkTopology | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute DEFAULT_OPERATOR_ID : String to DEFAULT_ID : String in class org.apache.flink.storm.wrappers.BoltWrapper | From | To | |
| Extract Variable | 1 | ||
| Extract Variable inputSchema1 : Fields in method private createOutput(boltId String, bolt IRichBolt, inputStreams Map<GlobalStreamId,DataStream<Tuple>>) : SingleOutputStreamOperator<?,?> from class org.apache.flink.storm.api.FlinkTopology | From | To |