           gdf_status = scatter_column<column_type>(input, 
                                                    num_rows,
                                                    row_output_locations, 
-                                                   output);
+                                                   output,
+                                                   column_streams[i]);
           break;
         }
       default:

  const size_type num_columns = input_table.get_num_columns();
  const size_type num_rows = input_table.get_column_length();

  // Scatter columns one by one
  for(size_type i = 0; i < num_columns; ++i)
  {

    if(GDF_SUCCESS != gdf_status)
      return gdf_status;
  }

  // Synchronize all the streams
  CUDA_TRY( cudaDeviceSynchronize() );

  // Destroy all streams
  for(auto & s : column_streams)
  {
    cudaStreamDestroy(s);
  }

  return gdf_status;
}

