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

Function MakeBackgroundGenerator

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

Source from the content-addressed store, hash-verified

1863/// This generator will queue up to max_q blocks
1864template <typename T>
1865static Result<AsyncGenerator<T>> MakeBackgroundGenerator(
1866 Iterator<T> iterator, internal::Executor* io_executor,
1867 int max_q = kDefaultBackgroundMaxQ, int q_restart = kDefaultBackgroundQRestart) {
1868 if (max_q < q_restart) {
1869 return Status::Invalid("max_q must be >= q_restart");
1870 }
1871 return BackgroundGenerator<T>(std::move(iterator), io_executor, max_q, q_restart);
1872}
1873
1874/// \brief Create an AsyncGenerator<T> by iterating over an Iterator<T> synchronously
1875///

Callers 10

ScanBatchesAsyncMethod · 0.85
genMethod · 0.85
MakeReaderGeneratorFunction · 0.85
genMethod · 0.85
MakeGeneratorMethod · 0.85
MakeGeneratorMethod · 0.85
MakeGeneratorMethod · 0.85
MakeGeneratorMethod · 0.85
TEST_PFunction · 0.85

Calls 1

InvalidFunction · 0.50

Tested by 4

ScanBatchesAsyncMethod · 0.68
genMethod · 0.68
genMethod · 0.68
TEST_PFunction · 0.68