Java InputRowBuilder inputRowBuilder = new MapBasedInputRowBuilder() .addColumn("timestamp", ValueType.LONG) .addColumn("name", ValueType.STRING) .addColumn("value", ValueType.DOUBLE); List<InputRow> rows = new ArrayList<>(); rows.add(inputRowBuilder.build(1619568000000L, "A", 10.5)); rows.add(inputRowBuilder.build(1619654400000L, "B", 20.8)); DruidClient.getInstance().loadData(rows); Java DruidQueryConfig queryConfig = new DruidQueryConfig.Builder() .setDataSource("my_datasource") .setInterval("2022-03-01T00:00:00Z/2022-03-02T00:00:00Z") .setGranularity("hour") .setQueryType(QueryType.GROUP_BY) .addGroupByDimension("name") .addAggregation(new Aggregation("value", AggregatorType.SUM)) .build(); DruidQueryResult result = DruidClient.getInstance().query(queryConfig); for (Row row : result.getRows()) { String name = row.getDimension("name"); double sumValue = row.getMetricValue("value"); System.out.println("Name: " + name + ", Sum Value: " + sumValue); }