[FLINK-8062][QS] Make getKvState() with namespace private.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/96b350ad Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/96b350ad Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/96b350ad Branch: refs/heads/release-1.4 Commit: 96b350ad91a1f248d0a3c616d1e59638013892be Parents: d0324e3 Author: kkloudas <kklou...@gmail.com> Authored: Wed Nov 15 15:32:42 2017 +0100 Committer: kkloudas <kklou...@gmail.com> Committed: Fri Nov 17 11:18:47 2017 +0100 ---------------------------------------------------------------------- .../flink/queryablestate/client/QueryableStateClient.java | 3 +-- .../itcases/AbstractQueryableStateTestBase.java | 7 +------ 2 files changed, 2 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/96b350ad/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java ---------------------------------------------------------------------- diff --git a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java index 304505a..03e02e1 100644 --- a/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java +++ b/flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/client/QueryableStateClient.java @@ -186,8 +186,7 @@ public class QueryableStateClient { * @param stateDescriptor The {@link StateDescriptor} of the state we want to query. * @return Future holding the immutable {@link State} object containing the result. */ - @PublicEvolving - public <K, N, S extends State, V> CompletableFuture<S> getKvState( + private <K, N, S extends State, V> CompletableFuture<S> getKvState( final JobID jobId, final String queryableStateName, final K key, http://git-wip-us.apache.org/repos/asf/flink/blob/96b350ad/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java ---------------------------------------------------------------------- diff --git a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java index c1cbb61..a789dbd 100644 --- a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java +++ b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/itcases/AbstractQueryableStateTestBase.java @@ -47,7 +47,6 @@ import org.apache.flink.configuration.Configuration; import org.apache.flink.queryablestate.client.QueryableStateClient; import org.apache.flink.queryablestate.client.VoidNamespace; import org.apache.flink.queryablestate.client.VoidNamespaceSerializer; -import org.apache.flink.queryablestate.client.VoidNamespaceTypeInfo; import org.apache.flink.queryablestate.exceptions.UnknownKeyOrNamespaceException; import org.apache.flink.runtime.concurrent.FutureUtils; import org.apache.flink.runtime.concurrent.ScheduledExecutor; @@ -491,9 +490,7 @@ public abstract class AbstractQueryableStateTestBase extends TestLogger { jobId, "wrong-hankuna", // this is the wrong name. 0, - VoidNamespace.INSTANCE, BasicTypeInfo.INT_TYPE_INFO, - VoidNamespaceTypeInfo.INSTANCE, valueState); try { @@ -572,9 +569,7 @@ public abstract class AbstractQueryableStateTestBase extends TestLogger { jobId, queryableState.getQueryableStateName(), 0, - VoidNamespace.INSTANCE, BasicTypeInfo.INT_TYPE_INFO, - VoidNamespaceTypeInfo.INSTANCE, valueState); cluster.submitJobDetached(jobGraph); @@ -1486,7 +1481,7 @@ public abstract class AbstractQueryableStateTestBase extends TestLogger { if (!resultFuture.isDone()) { Thread.sleep(100L); - CompletableFuture<S> expected = client.getKvState(jobId, queryName, key, VoidNamespace.INSTANCE, keyTypeInfo, VoidNamespaceTypeInfo.INSTANCE, stateDescriptor); + CompletableFuture<S> expected = client.getKvState(jobId, queryName, key, keyTypeInfo, stateDescriptor); expected.whenCompleteAsync((result, throwable) -> { if (throwable != null) { if (