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

Method MakeAsync

cpp/src/arrow/csv/reader.cc:1240–1246  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1238}
1239
1240Future<std::shared_ptr<StreamingReader>> StreamingReader::MakeAsync(
1241 io::IOContext io_context, std::shared_ptr<io::InputStream> input,
1242 Executor* cpu_executor, const ReadOptions& read_options,
1243 const ParseOptions& parse_options, const ConvertOptions& convert_options) {
1244 return MakeStreamingReader(io_context, std::move(input), cpu_executor, read_options,
1245 parse_options, convert_options);
1246}
1247
1248Future<int64_t> CountRowsAsync(io::IOContext io_context,
1249 std::shared_ptr<io::InputStream> input,

Callers

nothing calls this directly

Calls 1

MakeStreamingReaderFunction · 0.85

Tested by

no test coverage detected