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

Method GetThreadIndex

cpp/src/arrow/acero/query_context.cc:48–48  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

46}
47
48size_t QueryContext::GetThreadIndex() { return thread_indexer_(); }
49
50size_t QueryContext::max_concurrency() const { return thread_indexer_.Capacity(); }
51

Callers 6

InputReceivedMethod · 0.80
InputReceivedMethod · 0.80
InputFinishedMethod · 0.80
StartProducingMethod · 0.80
GetLocalStateMethod · 0.80
ConsumeMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected