如何将输出接收到 Hazelcast Jet 中的 json 文件？

Question

我是 Hazelcast Jet 的新手，在我的应用程序中我使用 jdbc 源，这个源返回 Map 列表，我必须在其中一个 json 文件中下沉但是当我使用 Sinks.json 它创建 json 目录我如何下沉它到特定的json文件？ 例如

           BatchSource<List<Map<String, Object>> jdbcSource = Sources
            .jdbc(() -> conn,
                (con, parallelism, index) -> {
                   // query execution
           }, r ->  {
                 return this.mapResultSet1(r);
           });
          jdbcSource.writeTo(Sinks.json("/opt/test.json"));

请告诉我如何将我的结果保存到 json 文件中？

Answer 1

考虑在接收到 JSON 文件之前将记录聚合到一个列表中。

jdbcSource
    .aggregate(AggregateOperations.toList())
    .writeTo(Sinks.json("directory-where-a-single-file-will-be-created"))