GitHub user zhztheplayer added a comment to the discussion: Flink support
@shuai-xu In current version of Velox4j, a viable method to emulate trivial `addInput` / `getOutput` invocations is to build an [ExternalStream](https://github.com/velox4j/velox4j/blob/9eb8eb43ee951bba9404fa846e09a995c149a8fc/src/test/java/io/github/zhztheplayer/velox4j/query/QueryTest.java#L220-L244) with a custom iterator that is backed by a `Queue<RowVector>`. When you tend to call `addInput`, you just push a `RowVector` to the queue. Then you could call `getOutput` on the `UpIterator` to get next output `RowVector` from Velox. This could be a simple solution at the moment and I will explore on better approaches soon. GitHub link: https://github.com/apache/incubator-gluten/discussions/8849#discussioncomment-12370861 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
