Method apply

bolt/functions/prestosql/ArrayAndMapMatch.cpp:62–119

  }

  void apply(
      const SelectivityVector& rows,
      std::vector<VectorPtr>& args,
      const TypePtr& /*outputType*/,
      exec::EvalCtx& context,
      VectorPtr& result) const override {
    exec::LocalDecodedVector decoder(context, *args[0], rows);
    auto& decodedContainer = *decoder.get();

    auto flatContainer = flattenContainer(rows, args[0], decodedContainer);
    auto* rawOffsets = flatContainer->rawOffsets();
    auto* rawSizes = flatContainer->rawSizes();

    std::vector<VectorPtr> lambdaArgs = {lambdaArgument(flatContainer)};
    const auto numElements = lambdaArgs[0]->size();

    context.ensureWritable(rows, BOOLEAN(), result);
    auto* flatResult = result->asFlatVector<bool>();

    VectorPtr matchBits;
    exec::LocalDecodedVector bitsDecoder(context);

    // Loop over lambda functions and apply these to elements of the base array,
    // in most cases there will be only one function and the loop will run once.
    auto it = args[1]->asUnchecked<FunctionVector>()->iterator(&rows);
    while (auto entry = it.next()) {
      auto elementRows = toElementRows<TContainer>(
          numElements, *entry.rows, flatContainer.get());
      auto wrapCapture = toWrapCapture<TContainer>(
          numElements, entry.callable, *entry.rows, flatContainer);

      ErrorVectorPtr elementErrors;
      entry.callable->applyNoThrow(
          elementRows,
          nullptr, // No need to preserve any values in 'matchBits'.
          wrapCapture,
          &context,
          lambdaArgs,
          elementErrors,
          &matchBits);

      bitsDecoder.get()->decode(*matchBits, elementRows);
      entry.rows->applyToSelected([&](vector_size_t row) {
        if (flatContainer->isNullAt(row)) {
          flatResult->setNull(row, true);
        } else {
          applyInternal(
              *flatResult,
              context,
              row,
              rawOffsets[row],
              rawSizes[row],
              elementErrors,
              bitsDecoder);
        }
      });
    }
  }