Method getOutput

bolt/exec/Generator.cpp:99–286

}

RowVectorPtr GeneratorExplode::getOutput() {
  if (!input_) {
    return nullptr;
  }

  auto size = input_->size();
  if (iterator_.rowOffset_ == 0) {
    inputRows_.resize(size);
    // process genInput
    preGen();
  }

  // The max number of elements at each row across all generated columns.
  auto maxSizes = AlignedBuffer::allocate<int64_t>(size, pool(), 0);
  auto rawMaxSizes = maxSizes->asMutable<int64_t>();

  std::vector<const vector_size_t*> rawSizes(1);
  std::vector<const vector_size_t*> rawOffsets(1);

  int32_t channel = 0;
  const auto& generateVector = genInput_[channel];

  auto& currentDecoded = generateDecoded_[channel];
  auto currentIndices = currentDecoded.indices();

  const ArrayVector* generateBaseArray;
  const MapVector* generateBaseMap;
  if (generateVector->typeKind() == TypeKind::ARRAY) {
    generateBaseArray = currentDecoded.base()->as<ArrayVector>();
    rawSizes[channel] = generateBaseArray->rawSizes();
    rawOffsets[channel] = generateBaseArray->rawOffsets();
  } else {
    BOLT_CHECK(generateVector->typeKind() == TypeKind::MAP);
    generateBaseMap = currentDecoded.base()->as<MapVector>();
    rawSizes[channel] = generateBaseMap->rawSizes();
    rawOffsets[channel] = generateBaseMap->rawOffsets();
  }

  // Count max number of elements per row.
  auto currentSizes = rawSizes[channel];
  int numElements = 0;
  bool isIdentityMapping = true;
  BufferPtr nulls = nullptr;
  BufferPtr elementIndices = nullptr;

  if (isOuter_) {
    calRepeatedCount<true>(
        currentDecoded,
        size,
        currentSizes,
        currentIndices,
        rawMaxSizes,
        numElements);
  } else {
    calRepeatedCount<false>(
        currentDecoded,
        size,
        currentSizes,