@@ -121,7 +121,9 @@ RowVectorPtr CudfFromVelox::getOutput() {
121121 auto input = mergeRowVectors (selectedInputs, inputs_[0 ]->pool ());
122122 // print physical type of each column in output
123123 for (auto i = 0 ; i < input->type ()->size (); i++) {
124- std::cout << " input column " << i << " type: " << input->childAt (i)->type ()->toString () << " " << input->childAt (i)->type ()->kindName () << std::endl;
124+ std::cout << " input column " << i
125+ << " type: " << input->childAt (i)->type ()->toString () << " "
126+ << input->childAt (i)->type ()->kindName () << std::endl;
125127 }
126128 // Remove processed inputs
127129 inputs_.erase (inputs_.begin (), inputs_.begin () + selectedInputs.size ());
@@ -137,9 +139,11 @@ RowVectorPtr CudfFromVelox::getOutput() {
137139
138140 // Convert RowVector to cudf table
139141 auto tbl = with_arrow::toCudfTable (input, input->pool (), stream);
140- // print types of tbl->view()
142+ // print types of tbl->view()
141143 for (auto i = 0 ; i < tbl->num_columns (); i++) {
142- std::cout << " input cudf column " << i << " type: " << static_cast <int >(tbl->get_column (i).type ().id ()) << std::endl;
144+ std::cout << " input cudf column " << i
145+ << " type: " << static_cast <int >(tbl->get_column (i).type ().id ())
146+ << std::endl;
143147 }
144148
145149 stream.synchronize ();
@@ -216,19 +220,25 @@ RowVectorPtr CudfToVelox::getOutput() {
216220
217221 // print types of tbl->view()
218222 for (auto i = 0 ; i < tbl->num_columns (); i++) {
219- std::cout << " cudf column " << i << " type: " << static_cast <int >(tbl->get_column (i).type ().id ()) << std::endl;
223+ std::cout << " cudf column " << i
224+ << " type: " << static_cast <int >(tbl->get_column (i).type ().id ())
225+ << std::endl;
220226 }
221227 stream.synchronize ();
222228 finished_ = noMoreInput_ && inputs_.empty ();
223229 std::cout << " output.type: " << output->type ()->toString () << std::endl;
224230 std::cout << " outputType_: " << outputType_->toString () << std::endl;
225231 // print physical type of each column in output
226232 for (auto i = 0 ; i < output->type ()->size (); i++) {
227- std::cout << " column " << i << " type: " << output->childAt (i)->type ()->toString () << " " << output->childAt (i)->type ()->kindName () << std::endl;
233+ std::cout << " column " << i
234+ << " type: " << output->childAt (i)->type ()->toString () << " "
235+ << output->childAt (i)->type ()->kindName () << std::endl;
228236 }
229237 // print physical type of each column in outputType_
230238 for (auto i = 0 ; i < outputType_->size (); i++) {
231- std::cout << " column " << i << " type: " << outputType_->childAt (i)->toString () << " " << outputType_->childAt (i)->kindName () << std::endl;
239+ std::cout << " column " << i
240+ << " type: " << outputType_->childAt (i)->toString () << " "
241+ << outputType_->childAt (i)->kindName () << std::endl;
232242 }
233243 output->setType (outputType_);
234244 return output;
0 commit comments