Method outputBatchByteSize

bolt/exec/StreamingAggregation.cpp:57–61

}

int64_t StreamingAggregation::outputBatchByteSize() const {
  const auto& queryConfig =
      this->operatorCtx()->task()->queryCtx()->queryConfig();
  return queryConfig.preferredOutputBatchBytes();
}

void StreamingAggregation::initialize() {
  Operator::initialize();