| Class | Description |
|---|---|
| BlobDataIteratorImpl |
| BlobIteratorImpl.next() 返回一个 LimitedInputStream,
| 它包装了下面的"干净的协议帧流",限定了单个Blob的Data范围
+-------------------------------------------------------------------------+
| BlobIteratorImpl (迭代器实现) |
| |
| - 它消费的是一个“干净的协议帧流”。 |
| - 它的工作是解析 [HeaderLen][Header][DataLen][Data]...
|
| CrcStrippedInputStream |
Strips CRC32C checksums from a stream formatted as:
[4096 bytes data][4 bytes CRC] ...
|
| DiskSpillingInputStream |
一个将输入流缓存到临时磁盘文件的可重复读流。
|
| LimitedInputStream |
一个 InputStream 包装器,它只允许从底层流中读取固定数量的字节。
它的 close() 方法不会关闭底层流。
|
| RawArrowRequestBody | |
| RepeatableFileInputStream |
A repeatable input stream that can reset to a marked position.
|
Copyright © 2026 Alibaba Cloud Computing. All rights reserved.