fixed client build

Author: chernser

client-v2/src/main/java/com/clickhouse/client/api/Client.java

@@ -92,26 +92,28 @@
  * <p>Client is the starting point for all interactions with ClickHouse. </p>
  *
  * <p>{@link Builder} is designed to construct a client object with required configuration:</p>
- *  <pre>{@code
+ * {@code
  *
  *  Client client = new Client.Builder()
  *        .addEndpoint(Protocol.HTTP, node.getHost(), node.getPort())
  *        .addUsername("default")
  *        .build();
- *        }
- *  </pre>
+ *  }
+ *
  *
  *
  * <p>When client object is created any operation method can be called on it:</p>
- * <pre>{@code
+ * {@code
  *
  *  if (client.ping()) {
  *      QuerySettings settings = new QuerySettings().setFormat(ClickHouseFormat.RowBinaryWithNamesAndTypes);
  *      try (QueryResponse response = client.query("SELECT * FROM " + table, settings).get(10, TimeUnit.SECONDS)) {
  *          ...
  *      }
  *  }
- * </pre>
+ *
+ * }
+ *
  *
  *
  * <p>Client is thread-safe. It uses exclusive set of object to perform an operation.</p>

examples/demo-service/src/main/java/com/clickhouse/demo_service/DatasetController.java

@@ -51,12 +51,14 @@ public DatasetController(Client chDirectClient) {
         this.chDirectClient = chDirectClient;
     }
 
+    public TableSchema datasetQuerySchema;
+
     @PostConstruct
     public void setup() {
         chDirectClient.ping(3000); // helps to warm up the connection
 
         // Register class for deserialization
-        TableSchema datasetQuerySchema = chDirectClient.getTableSchemaFromQuery(DATASET_QUERY, "virtual_table1");
+        datasetQuerySchema = chDirectClient.getTableSchemaFromQuery(DATASET_QUERY);
         chDirectClient.register(VirtualDatasetRecord.class, datasetQuerySchema);
         log.info("Dataset schema: " + datasetQuerySchema.getColumns());
 
@@ -198,7 +200,7 @@ private CalculationResult readToPOJO(int limit, boolean cache) {
         try  {
             long start = System.nanoTime();
 
-            result = chDirectClient.queryAll(query, VirtualDatasetRecord.class, objectsPool);
+            result = chDirectClient.queryAll(query, VirtualDatasetRecord.class, datasetQuerySchema, objectsPool);
             long duration = System.nanoTime() - start;
             log.info("records: " + result.size() + ", read time: " + TimeUnit.NANOSECONDS.toMillis(duration) + " ms");
             long p1Sum = 0;