refactor(api): refactor API to query state stores

This commit adds a new API to perform interactive queries.

azkarra-api/pom.xml

@@ -24,6 +24,7 @@
         <artifactId>azkarra-streams-reactor</artifactId>
         <version>0.9.0-SNAPSHOT</version>
     </parent>
+
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>azkarra-api</artifactId>

azkarra-api/src/main/java/io/streamthoughts/azkarra/api/config/Conf.java

@@ -119,7 +119,7 @@ static Conf of(final String k1, final Object v1,
      *
      * @return a new {@link Conf} instance.
      */
-    static Conf of(final Map<String, ?> map) {
+    static Conf of(final Map<String, Object> map) {
         return new MapConf(map);
     }
 

azkarra-api/src/main/java/io/streamthoughts/azkarra/api/query/DecorateQuery.java

@@ -0,0 +1,83 @@
+/*
+ * Copyright 2019-2021 StreamThoughts.
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.streamthoughts.azkarra.api.query;
+
+import java.util.Objects;
+
+public class DecorateQuery<T extends Query> implements Query {
+
+    protected final T query;
+
+    /**
+     * Creates a new {@link DecorateQuery} instance.
+     *
+     * @param query the query.
+     */
+    public DecorateQuery(final T query) {
+        this.query = Objects.requireNonNull(query, "query should not be null");
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public QueryParams getParams() {
+        return query.getParams();
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public String getStoreName() {
+        return query.getStoreName();
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public StoreOperation getStoreOperation() {
+        return query.getStoreOperation();
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public StoreType getStoreType() {
+        return query.getStoreType();
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public boolean equals(Object o) {
+        return query.equals(o);
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    @Override
+    public int hashCode() {
+        return Objects.hash(query);
+    }
+}