|
Pull Up Method public createInputSplits(minNumSplits int) : InputSplit[] from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to public createInputSplits(minNumSplits int) : InputSplit[] from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |
|
Pull Up Method public configure(parameters Configuration) : void from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to public configure(parameters Configuration) : void from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |
|
Pull Up Method public close() : void from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to public close() : void from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |
|
Pull Up Method public getInputSplitAssigner(inputSplits InputSplit[]) : InputSplitAssigner from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to public getInputSplitAssigner(inputSplits InputSplit[]) : InputSplitAssigner from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |
|
Pull Up Method public getStatistics(cachedStatistics BaseStatistics) : BaseStatistics from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to public getStatistics(cachedStatistics BaseStatistics) : BaseStatistics from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |
|
Pull Up Attribute private cluster : Cluster from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to protected cluster : Cluster from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |
|
Pull Up Attribute private session : Session from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to protected session : Session from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |
|
Pull Up Attribute private builder : ClusterBuilder from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to protected builder : ClusterBuilder from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |
|
Pull Up Attribute private LOG : Logger from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to private LOG : Logger from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |
|
Pull Up Attribute private query : String from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormat to protected query : String from class org.apache.flink.batch.connectors.cassandra.CassandraInputFormatBase |
From |
To |