| 28 | constexpr int64_t TableSourceNodeOptions::kDefaultMaxBatchSize; |
| 29 | |
| 30 | std::string ToString(JoinType t) { |
| 31 | switch (t) { |
| 32 | case JoinType::LEFT_SEMI: |
| 33 | return "LEFT_SEMI"; |
| 34 | case JoinType::RIGHT_SEMI: |
| 35 | return "RIGHT_SEMI"; |
| 36 | case JoinType::LEFT_ANTI: |
| 37 | return "LEFT_ANTI"; |
| 38 | case JoinType::RIGHT_ANTI: |
| 39 | return "RIGHT_ANTI"; |
| 40 | case JoinType::INNER: |
| 41 | return "INNER"; |
| 42 | case JoinType::LEFT_OUTER: |
| 43 | return "LEFT_OUTER"; |
| 44 | case JoinType::RIGHT_OUTER: |
| 45 | return "RIGHT_OUTER"; |
| 46 | case JoinType::FULL_OUTER: |
| 47 | return "FULL_OUTER"; |
| 48 | } |
| 49 | ARROW_LOG(FATAL) << "Invalid variant of arrow::compute::JoinType"; |
| 50 | std::abort(); |
| 51 | } |
| 52 | |
| 53 | namespace { |
| 54 | ExecBatchIteratorMaker VecToItMaker(std::vector<ExecBatch> batches) { |
no outgoing calls