|
Change Parameter Type partitionStateChecker : PartitionStateChecker to taskActions : TaskActions in method public create(owningTaskName String, jobId JobID, executionId ExecutionAttemptID, igdd InputGateDeploymentDescriptor, networkEnvironment NetworkEnvironment, taskActions TaskActions, metrics IOMetricGroup) : SingleInputGate in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Change Parameter Type partitionStateChecker : PartitionStateChecker to taskActions : TaskActions in method public SingleInputGate(owningTaskName String, jobId JobID, executionId ExecutionAttemptID, consumedResultId IntermediateDataSetID, consumedSubpartitionIndex int, numberOfInputChannels int, taskActions TaskActions, metrics IOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Change Parameter Type jobManagerCommunicationFactory : JobManagerCommunicationFactory to resultPartitionConsumableNotifier : ResultPartitionConsumableNotifier in method private createPartition(owningTask Task, name String, jobId JobID, eagerlyDeployConsumers boolean, env NetworkEnvironment, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier) : ResultPartition in class org.apache.flink.runtime.io.network.NetworkEnvironmentTest |
From |
To |
|
Rename Variable jobManagerCommunicationFactory : JobManagerCommunicationFactory to executor : Executor in method private createTask() : Task in class org.apache.flink.runtime.taskmanager.TaskAsyncCallTest |
From |
To |
|
Rename Variable jobManagerCommunicationFactory : JobManagerCommunicationFactory to executor : Executor in method private createTask(invokable Class<? extends AbstractInvokable>, taskConfig StreamConfig) : Task in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Rename Variable jobManagerCommunicationFactory : JobManagerCommunicationFactory to partitionStateChecker : PartitionStateChecker in method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager) : Task in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Rename Variable jobManagerCommunicationFactory : JobManagerCommunicationFactory to partitionStateChecker : PartitionStateChecker in method public testExecutionFailsInNetworkRegistration() : void in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Rename Variable jobManagerCommunicationFactory : JobManagerCommunicationFactory to resultPartitionConsumableNotifier : ResultPartitionConsumableNotifier in method public testEagerlyDeployConsumers() : void in class org.apache.flink.runtime.io.network.NetworkEnvironmentTest |
From |
To |
|
Change Variable Type jobManagerCommunicationFactory : JobManagerCommunicationFactory to executor : Executor in method private createTask() : Task in class org.apache.flink.runtime.taskmanager.TaskAsyncCallTest |
From |
To |
|
Change Variable Type jobManagerCommunicationFactory : JobManagerCommunicationFactory to executor : Executor in method private createTask(invokable Class<? extends AbstractInvokable>, taskConfig StreamConfig) : Task in class org.apache.flink.streaming.runtime.tasks.StreamTaskTest |
From |
To |
|
Change Variable Type jobManagerCommunicationFactory : JobManagerCommunicationFactory to partitionStateChecker : PartitionStateChecker in method private createTask(invokable Class<? extends AbstractInvokable>, libCache LibraryCacheManager) : Task in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Change Variable Type jobManagerCommunicationFactory : JobManagerCommunicationFactory to resultPartitionConsumableNotifier : ResultPartitionConsumableNotifier in method public testEagerlyDeployConsumers() : void in class org.apache.flink.runtime.io.network.NetworkEnvironmentTest |
From |
To |
|
Change Variable Type jobManagerCommunicationFactory : JobManagerCommunicationFactory to partitionStateChecker : PartitionStateChecker in method public testExecutionFailsInNetworkRegistration() : void in class org.apache.flink.runtime.taskmanager.TaskTest |
From |
To |
|
Rename Parameter partitionStateChecker : PartitionStateChecker to taskActions : TaskActions in method public SingleInputGate(owningTaskName String, jobId JobID, executionId ExecutionAttemptID, consumedResultId IntermediateDataSetID, consumedSubpartitionIndex int, numberOfInputChannels int, taskActions TaskActions, metrics IOMetricGroup) in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |
|
Rename Parameter jobManagerCommunicationFactory : JobManagerCommunicationFactory to resultPartitionConsumableNotifier : ResultPartitionConsumableNotifier in method private createPartition(owningTask Task, name String, jobId JobID, eagerlyDeployConsumers boolean, env NetworkEnvironment, resultPartitionConsumableNotifier ResultPartitionConsumableNotifier) : ResultPartition in class org.apache.flink.runtime.io.network.NetworkEnvironmentTest |
From |
To |
|
Rename Parameter partitionStateChecker : PartitionStateChecker to taskActions : TaskActions in method public create(owningTaskName String, jobId JobID, executionId ExecutionAttemptID, igdd InputGateDeploymentDescriptor, networkEnvironment NetworkEnvironment, taskActions TaskActions, metrics IOMetricGroup) : SingleInputGate in class org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate |
From |
To |