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

Function MakeChunkingGenerator

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

Source from the content-addressed store, hash-verified

230// internal state gets updated on each call.
231template <typename... Args>
232AsyncGenerator<ChunkedBlock> MakeChunkingGenerator(
233 AsyncGenerator<std::shared_ptr<Buffer>> source, Args&&... args) {
234 return MakeTransformedGenerator(std::move(source),
235 ChunkingTransformer::Make(std::forward<Args>(args)...));
236}
237
238class TableReaderImpl : public TableReader,
239 public std::enable_shared_from_this<TableReaderImpl> {

Callers 1

MakeAsyncMethod · 0.85

Calls 2

MakeTransformedGeneratorFunction · 0.85
MakeFunction · 0.50

Tested by

no test coverage detected