Toggle navigation
Home
org.apache.flink.runtime.io.network.NetworkEnvironment to org.apache.flink.runtime.shuffle.ShuffleEnvironment<?, ?>
No. of Instances - 14
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Rename Variable
networkEnvironment
to
shuffleEnvironment
createNetworkEnvironment
to
createShuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
optionalNetworkEnvironment
to
optionalShuffleEnvironment
optionalNetworkEnvironment
to
optionalShuffleEnvironment
optionalNetworkEnvironment
to
optionalShuffleEnvironment
optionalNetworkEnvironment
to
optionalShuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
network
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
networkEnvironment
to
shuffleEnvironment
Cascading Type Change (Similar)
NetworkEnvironment
to
ShuffleEnvironment<?,?>
NetworkEnvironment
to
ShuffleEnvironment
NetworkEnvironment
to
ShuffleEnvironment<?,?>
NetworkEnvironment
to
ShuffleEnvironment
Add or Remove Method invocation
optionalNetworkEnvironment.orElseGet(() -> { try { return createNetworkEnvironment(resourceID,localCommunication,configuration,testingRpcService,mockNetworkEnvironment); } catch ( Exception e) { throw new FlinkRuntimeException("Failed to build TaskSubmissionTestEnvironment",e); } } )
to
optionalShuffleEnvironment.orElseGet(() -> { try { return createShuffleEnvironment(resourceID,localCommunication,configuration,testingRpcService,mockShuffleEnvironment); } catch ( Exception e) { throw new FlinkRuntimeException("Failed to build TaskSubmissionTestEnvironment",e); } } )
new TaskManagerServicesBuilder().setNetworkEnvironment(networkEnvironment).setTaskSlotTable(taskSlotTable).setJobManagerTable(jobManagerTable).setTaskStateManager(localStateStoresManager)
to
new TaskManagerServicesBuilder().setShuffleEnvironment(shuffleEnvironment).setTaskSlotTable(taskSlotTable).setJobManagerTable(jobManagerTable).setTaskStateManager(localStateStoresManager)