MCPcopy Create free account
hub / github.com/apache/arrow / MakeChunkingIterator

Function MakeChunkingIterator

cpp/src/arrow/json/reader.cc:223–227  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

221
222template <typename... Args>
223Iterator<ChunkedBlock> MakeChunkingIterator(Iterator<std::shared_ptr<Buffer>> source,
224 Args&&... args) {
225 return MakeTransformedIterator(std::move(source),
226 ChunkingTransformer::Make(std::forward<Args>(args)...));
227}
228
229// NOTE: Not reentrant. Incoming buffers are processed sequentially and the transformer's
230// internal state gets updated on each call.

Callers 2

ReadMethod · 0.85
MakeAsyncMethod · 0.85

Calls 2

MakeTransformedIteratorFunction · 0.85
MakeFunction · 0.50

Tested by

no test coverage detected