Skip to content

Commit d6b9994

Browse files
committed
Rewrite SeaInlineArrowChunkProvider with rolling-window prefetch mirroring ThriftStreamingProvider
Replace synchronous lazy-fetch design with background prefetch thread using ReentrantLock + Condition signaling, ConcurrentHashMap for indexed chunk storage, and explicit chunksInMemory tracking for backpressure. This ensures consistency with ThriftStreamingProvider's design patterns. Signed-off-by: Gopal Lal <gopal.lal@databricks.com> Co-authored-by: Isaac Signed-off-by: Gopal Lal <gopal.lal@databricks.com>
1 parent eea02ab commit d6b9994

1 file changed

Lines changed: 332 additions & 84 deletions

File tree

0 commit comments

Comments
 (0)