MCPcopy Create free account
hub / github.com/apache/impala / batch_queue

Method batch_queue

be/src/exec/scan-node.h:259–259  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

257 int64_t timeout_micros);
258
259 BlockingRowBatchQueue* batch_queue() { return batch_queue_.get(); }
260 RuntimeProfile::ThreadCounters* thread_counters() const { return thread_counters_; }
261 int max_num_scanner_threads() const { return max_num_scanner_threads_; }
262 int64_t estimated_per_thread_mem() const { return estimated_per_thread_mem_; }

Callers 4

GetNextInternalMethod · 0.80
GetNextMethod · 0.80
ThreadAvailableCbMethod · 0.80

Calls 1

getMethod · 0.65

Tested by

no test coverage detected