Gooch0922 commented on PR #5960:
URL: https://github.com/apache/kyuubi/pull/5960#issuecomment-2997011588
For REST APIs and streaming queries, when calling the
{operationHandle}/rowset interface, users can specify an optional parameter
(similar to KyuubiConf.OPERATION_INCREMENTAL_COLLECT) to decide whether to
return cached data. The specific implementation approach is to modify the
IncrementalResultFetchIterator so that instead of blocking to fetch results
from Flink, a single-threaded scheduler periodically retrieves data from
Flink's Gateway API. This allows the system to determine if there is sufficient
data available. If not, it can directly return the data that is already cached.
@pan3793 cc
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@kyuubi.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@kyuubi.apache.org
For additional commands, e-mail: notifications-h...@kyuubi.apache.org
