Jingsong Lee created FLINK-26834:
------------------------------------
Summary: Introduce BlockingIterator to help testing
Key: FLINK-26834
URL: https://issues.apache.org/jira/browse/FLINK-26834
Project: Flink
Issue Type: Sub-task
Components: Table Store
Reporter: Jingsong Lee
Assignee: Jingsong Lee
Fix For: table-store-0.1.0
BlockingIterator provides the ability to bring timeout to blocking iterators.
It use a static cached \{@link ExecutorService}. We don't limit the number of
threads since the work inside is I/O type.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)