|
Pull Up Method public initializeState(operatorStateHandles OperatorStateHandles) : void from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public initializeState(operatorStateHandles OperatorStateHandles) : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public wasFailedExternally() : boolean from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public wasFailedExternally() : boolean from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public snapshotLegacy(checkpointId long, timestamp long) : StreamStateHandle from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public snapshotLegacy(checkpointId long, timestamp long) : StreamStateHandle from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public initializeState(operatorStateHandles OperatorStateHandles) : void from class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness to public initializeState(operatorStateHandles OperatorStateHandles) : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public close() : void from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public close() : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public setTimeCharacteristic(timeCharacteristic TimeCharacteristic) : void from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public setTimeCharacteristic(timeCharacteristic TimeCharacteristic) : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public setProcessingTime(time long) : void from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public setProcessingTime(time long) : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public setStateBackend(stateBackend AbstractStateBackend) : void from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public setStateBackend(stateBackend AbstractStateBackend) : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public open() : void from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public open() : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public notifyOfCompletedCheckpoint(checkpointId long) : void from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public notifyOfCompletedCheckpoint(checkpointId long) : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public snapshot(checkpointId long, timestamp long) : OperatorSnapshotResult from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public snapshot(checkpointId long, timestamp long) : OperatorSnapshotResult from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public open() : void from class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness to public open() : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public extractOutputStreamRecords() : List<StreamRecord<? extends OUT>> from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public extractOutputStreamRecords() : List<StreamRecord<? extends OUT>> from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public restore(snapshot StreamStateHandle) : void from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public restore(snapshot StreamStateHandle) : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public getCheckpointLock() : Object from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public getCheckpointLock() : Object from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public getTimeCharacteristic() : TimeCharacteristic from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public getTimeCharacteristic() : TimeCharacteristic from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public getOutput() : ConcurrentLinkedQueue<Object> from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public getOutput() : ConcurrentLinkedQueue<Object> from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public close() : void from class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness to public close() : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public getEnvironment() : Environment from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public getEnvironment() : Environment from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public setup() : void from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public setup() : void from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Method public getOutput() : ConcurrentLinkedQueue<Object> from class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness to public getOutput() : ConcurrentLinkedQueue<Object> from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package processingTimeService : TestProcessingTimeService from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to protected processingTimeService : TestProcessingTimeService from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package mockTask : StreamTask<?,?> from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to protected mockTask : StreamTask<?,?> from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package closableRegistry : ClosableRegistry from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to package closableRegistry : ClosableRegistry from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute private setupCalled : boolean from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to private setupCalled : boolean from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package checkpointLock : Object from class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness to private checkpointLock : Object from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute private initializeCalled : boolean from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to private initializeCalled : boolean from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute public MAX_PARALLELISM : int from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to public MAX_PARALLELISM : int from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package initializeCalled : boolean from class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness to private initializeCalled : boolean from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package executionConfig : ExecutionConfig from class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness to protected executionConfig : ExecutionConfig from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute private wasFailedExternally : boolean from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to private wasFailedExternally : boolean from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package config : StreamConfig from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to protected config : StreamConfig from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package outputList : ConcurrentLinkedQueue<Object> from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to protected outputList : ConcurrentLinkedQueue<Object> from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package closableRegistry : ClosableRegistry from class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness to package closableRegistry : ClosableRegistry from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package stateBackend : AbstractStateBackend from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to protected stateBackend : AbstractStateBackend from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute private checkpointLock : Object from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to private checkpointLock : Object from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package outputList : ConcurrentLinkedQueue<Object> from class org.apache.flink.streaming.util.TwoInputStreamOperatorTestHarness to protected outputList : ConcurrentLinkedQueue<Object> from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |
|
Pull Up Attribute package executionConfig : ExecutionConfig from class org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness to protected executionConfig : ExecutionConfig from class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness |
From |
To |