JSONマップを分散キャッシュに保存するApacheIgnite

JSONファイルからデータを読み取り、それをIgnite分散キャッシュにプッシュするために以下のコードを記述しました。このコードは正常に機能しますが、「ContainerAgg」クラスを作成する要件は私にとって問題です。私たちのデータ構造は事前定義されていません。抽出はユーザーの選択に基づいて動的に生成されます。

BinaryObjectを使用してみましたが、BinaryObjectを使用するとSQLクエリを実行できません。BinaryObjectを使用し、スキーマにプリコンパイルされたJavaクラスを使用しないサンプルはありますか。

この「StreamVisitorExample」がありますが、これはプリコンパイルされたJavaクラス（Instrument.class）を使用します

  public static void main(String[] args) {
    ObjectMapper mapper = new ObjectMapper();
    try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
      if (!ExamplesUtils.hasServerNodes(ignite))
        return;

      CacheConfiguration<String, ContainerAgg> config = new CacheConfiguration<>(MASSIVE_CACHE);

      config.setIndexedTypes(String.class, ContainerAgg.class);

      ignite.getOrCreateCache(config);


      try (BufferedReader br = new BufferedReader(new FileReader(args[0]))) {

        IgniteCache<String, ContainerAgg> cache = Ignition.ignite().cache(MASSIVE_CACHE);

        String line = null;
        Long cnt = 0L;
        while ((line = br.readLine()) != null) {
          ContainerAgg inst = mapper.readValue(line, ContainerAgg.class);
          cache.put(cnt.toString(), inst);
          cnt++;
        }


        long startTime = System.currentTimeMillis();
        String sql =
            "SELECT SFID, LABEL, PARTID, PROVIDERID, SUM(TOTALCNT) "
            + "FROM CONTAINERAGG GROUP BY SFID, LABEL, PARTID, PROVIDERID";

        QueryCursor<List<?>> cursor = cache.query(new SqlFieldsQuery(sql));
        long endTime = System.currentTimeMillis();

        for (List<?> row : cursor.getAll()){
          System.out.println(row);
        }
        System.out.println("Total Time: " + (endTime - startTime));

      } catch (FileNotFoundException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    }
  }

}

私が何をしたかについて、より多くのコンテキストを提供しますBinaryObject。JSONをに変換し、map各エントリをに追加してインスタンスをBinaryObjectBuilder作成しBinaryObject、に保存しましたIgniteCache<String, BinaryObject>