Method addInput

bolt/exec/StreamingAggregation.cpp:115–117

}

void StreamingAggregation::addInput(RowVectorPtr input) {
  input_ = std::move(input);
}

namespace {
// Compares a row in one vector with another row in another vector and returns