flink abd8af873a63869385e587b647ded3af7eb8a09a

abd8af873a63869385e587b647ded3af7eb8a09a

Files Diff

Added: 7
Removed: 0
Renamed: 0
Modified: 22

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Rename Method	1
Rename Method public getOperators() : Set<Tuple2<Integer,StreamOperator<?>>> renamed to public getAllOperatorFactory() : Set<Tuple2<Integer,StreamOperatorFactory<?>>> in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Change Parameter Type	5
Change Parameter Type operatorObject : StreamOperator<OUT> to operatorFactory : StreamOperatorFactory<OUT> in method public addOperator(vertexID Integer, slotSharingGroup String, coLocationGroup String, operatorFactory StreamOperatorFactory<OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Change Parameter Type operatorObject : StreamOperator<OUT> to operatorFactory : StreamOperatorFactory<OUT> in method public addSink(vertexID Integer, slotSharingGroup String, coLocationGroup String, operatorFactory StreamOperatorFactory<OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Change Parameter Type taskOperatorObject : TwoInputStreamOperator<IN1,IN2,OUT> to taskOperatorFactory : StreamOperatorFactory<OUT> in method public addCoOperator(vertexID Integer, slotSharingGroup String, coLocationGroup String, taskOperatorFactory StreamOperatorFactory<OUT>, in1TypeInfo TypeInformation<IN1>, in2TypeInfo TypeInformation<IN2>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Change Parameter Type operatorObject : StreamOperator<?> to operatorFactory : StreamOperatorFactory<?> in method protected addNode(vertexID Integer, slotSharingGroup String, coLocationGroup String, vertexClass Class<? extends AbstractInvokable>, operatorFactory StreamOperatorFactory<?>, operatorName String) : StreamNode in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Change Parameter Type operatorObject : StreamOperator<OUT> to operatorFactory : StreamOperatorFactory<OUT> in method public addSource(vertexID Integer, slotSharingGroup String, coLocationGroup String, operatorFactory StreamOperatorFactory<OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Change Return Type	1
Change Return Type Set<Tuple2<Integer,StreamOperator<?>>> to Set<Tuple2<Integer,StreamOperatorFactory<?>>> in method public getAllOperatorFactory() : Set<Tuple2<Integer,StreamOperatorFactory<?>>> in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Rename Attribute	4
Rename Attribute operator : StreamSink<T> to operatorFactory : StreamOperatorFactory<Object> in class org.apache.flink.streaming.api.transformations.SinkTransformation	From	To
Rename Attribute operator : TwoInputStreamOperator<IN1,IN2,OUT> to operatorFactory : StreamOperatorFactory<OUT> in class org.apache.flink.streaming.api.transformations.TwoInputTransformation	From	To
Rename Attribute operator : OneInputStreamOperator<IN,OUT> to operatorFactory : StreamOperatorFactory<OUT> in class org.apache.flink.streaming.api.transformations.OneInputTransformation	From	To
Rename Attribute operator : StreamSource<T,?> to operatorFactory : StreamOperatorFactory<T> in class org.apache.flink.streaming.api.transformations.SourceTransformation	From	To
Change Variable Type	5
Change Variable Type headOperator : StreamOperator<?> to headOperator : StreamOperatorFactory<?> in method public isChainable(edge StreamEdge, streamGraph StreamGraph) : boolean in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator	From	To
Change Variable Type operatorSet : Set<Tuple2<Integer,StreamOperator<?>>> to operatorSet : Set<Tuple2<Integer,StreamOperatorFactory<?>>> in method public getAllOperatorFactory() : Set<Tuple2<Integer,StreamOperatorFactory<?>>> in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Change Variable Type outOperator : StreamOperator<?> to outOperator : StreamOperatorFactory<?> in method private isChainable(edge StreamEdge, isChainingEnabled boolean, streamGraph StreamGraph) : boolean in class org.apache.flink.streaming.api.graph.StreamGraphHasherV2	From	To
Change Variable Type outOperator : StreamOperator<?> to outOperator : StreamOperatorFactory<?> in method public isChainable(edge StreamEdge, streamGraph StreamGraph) : boolean in class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator	From	To
Change Variable Type headOperator : StreamOperator<?> to headOperator : StreamOperatorFactory<?> in method private isChainable(edge StreamEdge, isChainingEnabled boolean, streamGraph StreamGraph) : boolean in class org.apache.flink.streaming.api.graph.StreamGraphHasherV2	From	To
Extract Interface	1
Extract Interface org.apache.flink.streaming.api.operators.SetupableStreamOperator from classes [org.apache.flink.streaming.api.operators.AbstractStreamOperator, org.apache.flink.table.runtime.OneInputOperatorWrapper, org.apache.flink.table.runtime.TwoInputOperatorWrapper]	From	To
Change Attribute Type	4
Change Attribute Type operator : TwoInputStreamOperator<IN1,IN2,OUT> to operatorFactory : StreamOperatorFactory<OUT> in class org.apache.flink.streaming.api.transformations.TwoInputTransformation	From	To
Change Attribute Type operator : StreamSink<T> to operatorFactory : StreamOperatorFactory<Object> in class org.apache.flink.streaming.api.transformations.SinkTransformation	From	To
Change Attribute Type operator : OneInputStreamOperator<IN,OUT> to operatorFactory : StreamOperatorFactory<OUT> in class org.apache.flink.streaming.api.transformations.OneInputTransformation	From	To
Change Attribute Type operator : StreamSource<T,?> to operatorFactory : StreamOperatorFactory<T> in class org.apache.flink.streaming.api.transformations.SourceTransformation	From	To
Extract Method	2
Extract Method public getStreamOperatorFactory(cl ClassLoader) : T extracted from public getStreamOperator(cl ClassLoader) : T in class org.apache.flink.streaming.api.graph.StreamConfig	From	To
Extract Method public setStreamOperatorFactory(factory StreamOperatorFactory<?>) : void extracted from public setStreamOperator(operator StreamOperator<?>) : void in class org.apache.flink.streaming.api.graph.StreamConfig	From	To
Rename Parameter	5
Rename Parameter operatorObject : StreamOperator<OUT> to operatorFactory : StreamOperatorFactory<OUT> in method public addOperator(vertexID Integer, slotSharingGroup String, coLocationGroup String, operatorFactory StreamOperatorFactory<OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Rename Parameter operatorObject : StreamOperator<OUT> to operatorFactory : StreamOperatorFactory<OUT> in method public addSink(vertexID Integer, slotSharingGroup String, coLocationGroup String, operatorFactory StreamOperatorFactory<OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Rename Parameter taskOperatorObject : TwoInputStreamOperator<IN1,IN2,OUT> to taskOperatorFactory : StreamOperatorFactory<OUT> in method public addCoOperator(vertexID Integer, slotSharingGroup String, coLocationGroup String, taskOperatorFactory StreamOperatorFactory<OUT>, in1TypeInfo TypeInformation<IN1>, in2TypeInfo TypeInformation<IN2>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Rename Parameter operatorObject : StreamOperator<?> to operatorFactory : StreamOperatorFactory<?> in method protected addNode(vertexID Integer, slotSharingGroup String, coLocationGroup String, vertexClass Class<? extends AbstractInvokable>, operatorFactory StreamOperatorFactory<?>, operatorName String) : StreamNode in class org.apache.flink.streaming.api.graph.StreamGraph	From	To
Rename Parameter operatorObject : StreamOperator<OUT> to operatorFactory : StreamOperatorFactory<OUT> in method public addSource(vertexID Integer, slotSharingGroup String, coLocationGroup String, operatorFactory StreamOperatorFactory<OUT>, inTypeInfo TypeInformation<IN>, outTypeInfo TypeInformation<OUT>, operatorName String) : void in class org.apache.flink.streaming.api.graph.StreamGraph	From	To

abd8af873a63869385e587b647ded3af7eb8a09a

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: