message: removing debug statements
diff: @@ -167,54 +167,33 @@ bool ArrowAllToAll::onReceive(int source, void *buffer, int length) {
  // create the buffer hosting the value
  std::shared_ptr<arrow::Buffer> buf = std::make_shared<arrow::Buffer>(
  static_cast<uint8_t *>(buffer), length);
  - debug(this->workerId_, "before push");
  table->buffers.push_back(buf);
  - debug(this->workerId_, "after push");
  // now check weather we have the expected number of buffers received
  if (table->noBuffers == table->bufferIndex + 1) {
  // okay we are done with this array
  std::shared_ptr<arrow::ArrayData> data = arrow::ArrayData::Make(
  schema_->field(table->columnIndex)->type(), table->length, table->buffers);
  // clears the buffers
  - debug(this->workerId_, "before clear buffers");
  table->buffers.clear();
  - debug(this->workerId_, "after clear buffers");
  // create an array
  std::shared_ptr<arrow::Array> array = arrow::MakeArray(data);
  - debug(this->workerId_, "before push array");
  table->arrays.push_back(array);
  - debug(this->workerId_, "after push array");
  // we have received all the arrays of the chunk array
  - debug(this->workerId_, "before if");
  if (table->arrays.size() == static_cast<size_t>(table->noArray)) {
  std::shared_ptr<arrow::ChunkedArray> chunkedArray = std::make_shared<arrow::ChunkedArray>(
  table->arrays, schema_->field(table->columnIndex)->type());
  // clear the arrays
  - debug(this->workerId_, "before clear arrays");
  table->arrays.clear();
  - debug(this->workerId_, "after clear arrays");
  -
  - debug(this->workerId_, "before push chunk array");
  table->currentArrays.push_back(chunkedArray);
  - debug(this->workerId_, "after push chunk array");
  -
  - debug(this->workerId_, "before nested if");
  if (table->currentArrays.size() == static_cast<size_t>(schema_->num_fields())) {
  // now we can create the table
  std::shared_ptr<arrow::Table> tablePtr = arrow::Table::Make(schema_, table->currentArrays);
  // clear the current array
  - debug(this->workerId_, "before clear chunk arrays");
  table->currentArrays.clear();
  - debug(this->workerId_, "after clear chunk arrays");
  -
  - debug(this->workerId_, "before call on recv");
  recv_callback_->onReceive(source, tablePtr);
  - debug(this->workerId_, "after call on recv");
  }
  - debug(this->workerId_, "after nested if");
  }
  - debug(this->workerId_, "after if");
  }
  return true;
  