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

Function MakeReadaheadGenerator

cpp/src/arrow/util/async_generator.h:979–982  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

977/// This generator may queue up to max_readahead instances of T
978template <typename T>
979AsyncGenerator<T> MakeReadaheadGenerator(AsyncGenerator<T> source_generator,
980 int max_readahead) {
981 return ReadaheadGenerator<T>(std::move(source_generator), max_readahead);
982}
983
984/// \brief Creates a generator that will yield finished futures from a vector
985///

Callers 7

MakeScanNodeFunction · 0.85
ScanBatchesAsyncMethod · 0.85
SetUpMethod · 0.85
StreamingReaderImplMethod · 0.85
TESTFunction · 0.85
TEST_PFunction · 0.85
InitFromBlockMethod · 0.85

Calls

no outgoing calls

Tested by 3

SetUpMethod · 0.68
TESTFunction · 0.68
TEST_PFunction · 0.68