|
Move Method private traverseStreamGraphAndGenerateHashes() : Map<Integer,byte[]> from class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator to public traverseStreamGraphAndGenerateHashes(streamGraph StreamGraph) : Map<Integer,byte[]> from class org.apache.flink.migration.streaming.api.graph.StreamGraphHasherV1 |
From |
To |
|
Move Method private generateDeterministicHash(node StreamNode, hasher Hasher, hashes Map<Integer,byte[]>) : byte[] from class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator to private generateDeterministicHash(node StreamNode, hasher Hasher, hashes Map<Integer,byte[]>, isChainingEnabled boolean) : byte[] from class org.apache.flink.migration.streaming.api.graph.StreamGraphHasherV1 |
From |
To |
|
Move Method private generateNodeHash(node StreamNode, hashFunction HashFunction, hashes Map<Integer,byte[]>) : boolean from class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator to private generateNodeHash(node StreamNode, hashFunction HashFunction, hashes Map<Integer,byte[]>, isChainingEnabled boolean) : boolean from class org.apache.flink.migration.streaming.api.graph.StreamGraphHasherV1 |
From |
To |
|
Move Method private generateNodeLocalHash(node StreamNode, hasher Hasher, id int) : void from class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator to private generateNodeLocalHash(node StreamNode, hasher Hasher, id int) : void from class org.apache.flink.migration.streaming.api.graph.StreamGraphHasherV1 |
From |
To |
|
Move Method private generateUserSpecifiedHash(node StreamNode, hasher Hasher) : byte[] from class org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator to private generateUserSpecifiedHash(node StreamNode, hasher Hasher) : byte[] from class org.apache.flink.migration.streaming.api.graph.StreamGraphHasherV1 |
From |
To |