在 Java 中创建一个 graphql api，用于流式传输 arrowflight 流

问：

我需要创建一个 graphql api，它流式传输 arrowflight 流。我找不到任何可以帮助我找到在 Java 中执行此操作的方法的文档。下面是我拥有的示例代码：

    String query = String.format(
            "SELECT %s FROM <table> ORDER BY %s LIMIT %s OFFSET %s",
            String.join(",", fieldNames), String.join(",", orderByList), limit, offset);

    FlightStream flightStream = arrowFlightClientService.initiateQuery(query);
    while (flightStream.next()) {
      .....//need to return each stream response as a stream which can be subscribed by the client
    }
    flightStream.close();

指向任何文档/代码的任何帮助都会很棒。