|
Change Parameter Type port : int to proxyPortRange : Iterator<Integer> in method public QueryableStateConfiguration(enabled boolean, proxyPortRange Iterator<Integer>, numServerThreads int, numQueryThreads int) in class org.apache.flink.runtime.taskexecutor.QueryableStateConfiguration |
From |
To |
|
Change Parameter Type port : int to ports : Iterator<Integer> in method public createKvStateClientProxy(address InetAddress, ports Iterator<Integer>, eventLoopThreads int, queryThreads int, stats KvStateRequestStats) : KvStateClientProxy in class org.apache.flink.runtime.query.QueryableStateUtils |
From |
To |
|
Change Parameter Type bindPort : Integer to bindPortIterator : Iterator<Integer> in method public KvStateClientProxyImpl(bindAddress InetAddress, bindPortIterator Iterator<Integer>, numEventLoopThreads Integer, numQueryThreads Integer, stats KvStateRequestStats) in class org.apache.flink.queryablestate.client.proxy.KvStateClientProxyImpl |
From |
To |
|
Rename Parameter port : int to proxyPortRange : Iterator<Integer> in method public QueryableStateConfiguration(enabled boolean, proxyPortRange Iterator<Integer>, numServerThreads int, numQueryThreads int) in class org.apache.flink.runtime.taskexecutor.QueryableStateConfiguration |
From |
To |
|
Rename Parameter port : int to ports : Iterator<Integer> in method public createKvStateClientProxy(address InetAddress, ports Iterator<Integer>, eventLoopThreads int, queryThreads int, stats KvStateRequestStats) : KvStateClientProxy in class org.apache.flink.runtime.query.QueryableStateUtils |
From |
To |
|
Rename Parameter bindPort : Integer to bindPortIterator : Iterator<Integer> in method public KvStateClientProxyImpl(bindAddress InetAddress, bindPortIterator Iterator<Integer>, numEventLoopThreads Integer, numQueryThreads Integer, stats KvStateRequestStats) in class org.apache.flink.queryablestate.client.proxy.KvStateClientProxyImpl |
From |
To |