flink f5d719096083504a0b5827e35c1d28e1180e5e1d

f5d719096083504a0b5827e35c1d28e1180e5e1d

Files Diff

Added: 3
Removed: 2
Renamed: 0
Modified: 4

Link to commit

Dependency Action

Refactorings reported:

	Refactoring Name	Occurences
	Move Class	2
	Move Class org.apache.flink.util.HDFSCopyToLocal moved to org.apache.flink.contrib.streaming.state.HDFSCopyToLocal	From	To
	Move Class org.apache.flink.util.HDFSCopyFromLocal moved to org.apache.flink.contrib.streaming.state.HDFSCopyFromLocal	From	To
	Rename Attribute	1
	Rename Attribute dbPath : File to basePath : File in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot	From	To
	Extract Variable	2
	Extract Variable hadoopConf : Configuration in method public main(args String[]) : void from class org.apache.flink.contrib.streaming.state.HDFSCopyToLocal	From	To
	Extract Variable hadoopConf : Configuration in method public main(args String[]) : void from class org.apache.flink.contrib.streaming.state.HDFSCopyFromLocal	From	To
	Rename Parameter	5
	Rename Parameter dbPath : File to basePath : File in method public AbstractRocksDBSnapshot(basePath File, checkpointPath String, backupUri URI, checkpointId long, keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, stateDesc SD) in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot	From	To
	Rename Parameter dbPath : File to basePath : File in method protected abstract createRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, stateDesc SD, basePath File, backupPath String, restorePath String, options Options) : KvState<K,N,S,SD,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.AbstractRocksDBState.AbstractRocksDBSnapshot	From	To
	Rename Parameter dbPath : File to basePath : File in method protected createRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, stateDesc ListStateDescriptor<V>, basePath File, backupPath String, restorePath String, options Options) : KvState<K,N,ListState<V>,ListStateDescriptor<V>,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.RocksDBListState.Snapshot	From	To
	Rename Parameter dbPath : File to basePath : File in method protected createRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, stateDesc ReducingStateDescriptor<V>, basePath File, backupPath String, restorePath String, options Options) : KvState<K,N,ReducingState<V>,ReducingStateDescriptor<V>,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.RocksDBReducingState.Snapshot	From	To
	Rename Parameter dbPath : File to basePath : File in method protected createRocksDBState(keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, stateDesc ValueStateDescriptor<V>, basePath File, backupPath String, restorePath String, options Options) : KvState<K,N,ValueState<V>,ValueStateDescriptor<V>,RocksDBStateBackend> in class org.apache.flink.contrib.streaming.state.RocksDBValueState.Snapshot	From	To