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

Method UpdateFilterBitVector

cpp/src/arrow/acero/swiss_join.cc:1911–1918  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1909}
1910
1911void JoinResidualFilter::UpdateFilterBitVector(int batch_start_row, int num_batch_rows,
1912 const uint16_t* batch_row_ids,
1913 uint8_t* filter_bitvector) {
1914 for (int i = 0; i < num_batch_rows; ++i) {
1915 int bit_idx = batch_row_ids[i] - batch_start_row;
1916 bit_util::SetBitTo(filter_bitvector, bit_idx, 1);
1917 }
1918}
1919
1920Status JoinResidualFilter::FilterLeftSemi(const ExecBatch& keypayload_batch,
1921 int batch_start_row, int num_batch_rows,

Callers 1

OnNextBatchMethod · 0.80

Calls 1

SetBitToFunction · 0.50

Tested by

no test coverage detected