|
Change Parameter Type stateDescriptor : StateDescriptor<?,V> to stateDescriptor : StateDescriptor<S,V> in method public getKvState(jobId JobID, queryableStateName String, key K, keyTypeInfo TypeInformation<K>, stateDescriptor StateDescriptor<S,V>) : CompletableFuture<S> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Parameter Type stateDescriptor : StateDescriptor<?,V> to stateDescriptor : StateDescriptor<S,V> in method public getKvState(jobId JobID, queryableStateName String, key K, keyTypeHint TypeHint<K>, stateDescriptor StateDescriptor<S,V>) : CompletableFuture<S> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Parameter Type valueSerializer : TypeSerializer<V> to stateDescriptor : StateDescriptor<?,V> in method public QueryableStateStream(queryableStateName String, stateDescriptor StateDescriptor<?,V>, keySerializer TypeSerializer<K>) in class org.apache.flink.streaming.api.datastream.QueryableStateStream |
From |
To |
|
Change Parameter Type stateDescriptor : StateDescriptor<?,Tuple2<Integer,Long>> to stateDescriptor : ValueStateDescriptor<Tuple2<Integer,Long>> in method private executeValueQuery(deadline Deadline, client QueryableStateClient, jobId JobID, queryableStateName String, stateDescriptor ValueStateDescriptor<Tuple2<Integer,Long>>, expected long) : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Parameter Type stateSerializer : TypeSerializer<V> to stateDescriptor : StateDescriptor<S,V> in method public getKvState(jobId JobID, queryableStateName String, key K, namespace N, keyTypeInfo TypeInformation<K>, namespaceTypeInfo TypeInformation<N>, stateDescriptor StateDescriptor<S,V>) : CompletableFuture<S> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Parameter Type stateDescriptor : StateDescriptor<?,V> to stateDescriptor : StateDescriptor<S,V> in method private getKvStateWithRetries(client QueryableStateClient, jobId JobID, queryName String, key K, keyTypeInfo TypeInformation<K>, stateDescriptor StateDescriptor<S,V>, retryDelay Time, failForUnknownKeyOrNamespace boolean, executor ScheduledExecutor) : CompletableFuture<S> in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Return Type CompletableFuture<V> to CompletableFuture<S> in method public getKvState(jobId JobID, queryableStateName String, key K, namespace N, keyTypeInfo TypeInformation<K>, namespaceTypeInfo TypeInformation<N>, stateDescriptor StateDescriptor<S,V>) : CompletableFuture<S> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Return Type CompletableFuture<V> to CompletableFuture<S> in method private getKvStateWithRetries(client QueryableStateClient, jobId JobID, queryName String, key K, keyTypeInfo TypeInformation<K>, stateDescriptor StateDescriptor<S,V>, retryDelay Time, failForUnknownKeyOrNamespace boolean, executor ScheduledExecutor) : CompletableFuture<S> in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Return Type CompletableFuture<V> to CompletableFuture<S> in method public getKvState(jobId JobID, queryableStateName String, key K, keyTypeHint TypeHint<K>, stateDescriptor StateDescriptor<S,V>) : CompletableFuture<S> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Return Type CompletableFuture<V> to CompletableFuture<S> in method public getKvState(jobId JobID, queryableStateName String, key K, keyTypeInfo TypeInformation<K>, stateDescriptor StateDescriptor<S,V>) : CompletableFuture<S> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Change Variable Type future : CompletableFuture<Tuple2<Integer,Long>> to future : CompletableFuture<ValueState<Tuple2<Integer,Long>>> in method private executeValueQuery(deadline Deadline, client QueryableStateClient, jobId JobID, queryableStateName String, stateDescriptor ValueStateDescriptor<Tuple2<Integer,Long>>, expected long) : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type result : CompletableFuture<Tuple2<Integer,Long>> to result : CompletableFuture<ReducingState<Tuple2<Integer,Long>>> in method public testQueryableState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type future : CompletableFuture<Tuple2<Integer,Long>> to future : CompletableFuture<ValueState<Tuple2<Integer,Long>>> in method public testValueStateDefault() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Change Variable Type futures : List<CompletableFuture<Tuple2<Integer,Long>>> to futures : List<CompletableFuture<ReducingState<Tuple2<Integer,Long>>>> in method public testQueryableState() : void in class org.apache.flink.queryablestate.itcases.AbstractQueryableStateITCase |
From |
To |
|
Rename Parameter stateSerializer : TypeSerializer<V> to stateDescriptor : StateDescriptor<S,V> in method public getKvState(jobId JobID, queryableStateName String, key K, namespace N, keyTypeInfo TypeInformation<K>, namespaceTypeInfo TypeInformation<N>, stateDescriptor StateDescriptor<S,V>) : CompletableFuture<S> in class org.apache.flink.queryablestate.client.QueryableStateClient |
From |
To |
|
Rename Parameter valueSerializer : TypeSerializer<V> to stateDescriptor : StateDescriptor<?,V> in method public QueryableStateStream(queryableStateName String, stateDescriptor StateDescriptor<?,V>, keySerializer TypeSerializer<K>) in class org.apache.flink.streaming.api.datastream.QueryableStateStream |
From |
To |