Add cudf_streaming to clang-format IncludeCategories

.clang-format

@@ -81,7 +81,7 @@ IncludeCategories:
     Priority:        3
   - Regex:           '^<cudf/' # cuDF includes
     Priority:        4
-  - Regex:           '^<(nvtext|cudf_kafka)' # other libcudf includes
+  - Regex:           '^<(nvtext|cudf_kafka|cudf_streaming)' # other libcudf includes
     Priority:        5
   - Regex:           '^<(cugraph|cuml|raft|kvikio)' # Other RAPIDS includes
     Priority:        6

cpp/libcudf_streaming/benchmarks/bench_partition.cpp

@@ -9,13 +9,14 @@
 #include <cudf/types.hpp>
 #include <cudf/utilities/error.hpp>
 
+#include <cudf_streaming/integrations/partition.hpp>
+
 #include <rmm/cuda_stream_view.hpp>
 #include <rmm/device_buffer.hpp>
 #include <rmm/mr/cuda_memory_resource.hpp>
 #include <rmm/mr/pool_memory_resource.hpp>
 
 #include <benchmark/benchmark.h>
-#include <cudf_streaming/integrations/partition.hpp>
 #include <rapidsmpf/utils/misc.hpp>
 
 #include <memory>

cpp/libcudf_streaming/benchmarks/bench_shuffle.cpp

@@ -4,6 +4,7 @@
  */
 
 #include <cudf_streaming/integrations/partition.hpp>
+
 #include <rapidsmpf/bootstrap/bootstrap.hpp>
 #include <rapidsmpf/bootstrap/utils.hpp>
 #include <rapidsmpf/communicator/communicator.hpp>

cpp/libcudf_streaming/benchmarks/streaming/bench_streaming_shuffle.cpp

@@ -11,6 +11,7 @@
 #include <cudf_streaming/integrations/partition.hpp>
 #include <cudf_streaming/streaming/partition.hpp>
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rapidsmpf/bootstrap/bootstrap.hpp>
 #include <rapidsmpf/bootstrap/utils.hpp>
 #include <rapidsmpf/communicator/communicator.hpp>

cpp/libcudf_streaming/benchmarks/streaming/data_generator.hpp

@@ -11,6 +11,7 @@
 #include <cudf/types.hpp>
 
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rapidsmpf/streaming/core/actor.hpp>
 #include <rapidsmpf/streaming/core/channel.hpp>
 #include <rapidsmpf/streaming/core/context.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/bench_read.cpp

@@ -9,13 +9,14 @@
 #include <cudf/io/types.hpp>
 #include <cudf/types.hpp>
 
+#include <cudf_streaming/streaming/parquet.hpp>
+
 #include <rmm/detail/format.hpp>
 #include <rmm/mr/cuda_async_memory_resource.hpp>
 
 #include <cuda_runtime_api.h>
 
 #include <coro/when_all.hpp>
-#include <cudf_streaming/streaming/parquet.hpp>
 #include <getopt.h>
 #include <rapidsmpf/memory/memory_type.hpp>
 #include <rapidsmpf/nvtx.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/concatenate.cpp

@@ -10,6 +10,7 @@
 #include <cudf/table/table_view.hpp>
 
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rapidsmpf/cuda_event.hpp>
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/streaming/core/channel.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/groupby.cpp

@@ -10,6 +10,7 @@
 #include <cudf/types.hpp>
 
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rapidsmpf/communicator/communicator.hpp>
 #include <rapidsmpf/streaming/core/channel.hpp>
 #include <rapidsmpf/streaming/core/context.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/join.cpp

@@ -16,10 +16,11 @@
 #include <cudf/types.hpp>
 #include <cudf/utilities/span.hpp>
 
-#include <rmm/cuda_stream_view.hpp>
-
 #include <cudf_streaming/integrations/partition.hpp>
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
+#include <rmm/cuda_stream_view.hpp>
+
 #include <rapidsmpf/communicator/communicator.hpp>
 #include <rapidsmpf/cuda_event.hpp>
 #include <rapidsmpf/cuda_stream.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/parquet_writer.cpp

@@ -9,6 +9,7 @@
 #include <cudf/io/types.hpp>
 
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/streaming/core/channel.hpp>
 #include <rapidsmpf/streaming/core/context.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/q01.cpp

@@ -21,12 +21,13 @@
 #include <cudf/types.hpp>
 #include <cudf/wrappers/timestamps.hpp>
 
+#include <cudf_streaming/streaming/parquet.hpp>
+#include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rmm/mr/cuda_async_memory_resource.hpp>
 
 #include <cuda_runtime_api.h>
 
-#include <cudf_streaming/streaming/parquet.hpp>
-#include <cudf_streaming/streaming/table_chunk.hpp>
 #include <rapidsmpf/communicator/communicator.hpp>
 #include <rapidsmpf/nvtx.hpp>
 #include <rapidsmpf/streaming/coll/allgather.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/q03.cpp

@@ -25,14 +25,15 @@
 #include <cudf/types.hpp>
 #include <cudf/wrappers/timestamps.hpp>
 
-#include <rmm/mr/cuda_async_memory_resource.hpp>
-
-#include <cuda_runtime_api.h>
-
 #include <cudf_streaming/integrations/partition.hpp>
 #include <cudf_streaming/streaming/bloom_filter.hpp>
 #include <cudf_streaming/streaming/parquet.hpp>
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
+#include <rmm/mr/cuda_async_memory_resource.hpp>
+
+#include <cuda_runtime_api.h>
+
 #include <driver_types.h>
 #include <rapidsmpf/communicator/communicator.hpp>
 #include <rapidsmpf/cuda_event.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/q04.cpp

@@ -24,14 +24,15 @@
 #include <cudf/types.hpp>
 #include <cudf/wrappers/timestamps.hpp>
 
+#include <cudf_streaming/streaming/bloom_filter.hpp>
+#include <cudf_streaming/streaming/parquet.hpp>
+#include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rmm/mr/cuda_async_memory_resource.hpp>
 
 #include <cuda/std/chrono>
 #include <cuda_runtime_api.h>
 
-#include <cudf_streaming/streaming/bloom_filter.hpp>
-#include <cudf_streaming/streaming/parquet.hpp>
-#include <cudf_streaming/streaming/table_chunk.hpp>
 #include <rapidsmpf/communicator/communicator.hpp>
 #include <rapidsmpf/nvtx.hpp>
 #include <rapidsmpf/streaming/coll/allgather.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/q09.cpp

@@ -25,12 +25,13 @@
 #include <cudf/transform.hpp>
 #include <cudf/types.hpp>
 
+#include <cudf_streaming/streaming/parquet.hpp>
+#include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rmm/mr/cuda_async_memory_resource.hpp>
 
 #include <cuda_runtime_api.h>
 
-#include <cudf_streaming/streaming/parquet.hpp>
-#include <cudf_streaming/streaming/table_chunk.hpp>
 #include <rapidsmpf/communicator/communicator.hpp>
 #include <rapidsmpf/nvtx.hpp>
 #include <rapidsmpf/streaming/coll/allgather.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/q21.cpp

@@ -22,14 +22,15 @@
 #include <cudf/table/table.hpp>
 #include <cudf/types.hpp>
 
+#include <cudf_streaming/streaming/bloom_filter.hpp>
+#include <cudf_streaming/streaming/parquet.hpp>
+#include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rmm/mr/cuda_async_memory_resource.hpp>
 
 #include <cuda_runtime_api.h>
 
 #include <coro/when_all.hpp>
-#include <cudf_streaming/streaming/bloom_filter.hpp>
-#include <cudf_streaming/streaming/parquet.hpp>
-#include <cudf_streaming/streaming/table_chunk.hpp>
 #include <rapidsmpf/communicator/communicator.hpp>
 #include <rapidsmpf/nvtx.hpp>
 #include <rapidsmpf/rmm_resource_adaptor.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/sort.cpp

@@ -9,6 +9,7 @@
 #include <cudf/types.hpp>
 
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rapidsmpf/streaming/core/channel.hpp>
 #include <rapidsmpf/streaming/core/context.hpp>
 

cpp/libcudf_streaming/benchmarks/streaming/ndsh/utils.cpp

@@ -8,11 +8,12 @@
 #include <cudf/io/parquet.hpp>
 #include <cudf/io/parquet_metadata.hpp>
 
+#include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rmm/aligned.hpp>
 #include <rmm/cuda_device.hpp>
 #include <rmm/mr/per_device_resource.hpp>
 
-#include <cudf_streaming/streaming/table_chunk.hpp>
 #include <getopt.h>
 #include <rapidsmpf/bootstrap/bootstrap.hpp>
 #include <rapidsmpf/bootstrap/utils.hpp>

cpp/libcudf_streaming/benchmarks/streaming/ndsh/utils.hpp

@@ -10,12 +10,13 @@
 #include <cudf/utilities/error.hpp>
 #include <cudf/wrappers/timestamps.hpp>
 
+#include <cudf_streaming/streaming/parquet.hpp>
+#include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rmm/cuda_stream_view.hpp>
 
 #include <cuda/memory_resource>
 
-#include <cudf_streaming/streaming/parquet.hpp>
-#include <cudf_streaming/streaming/table_chunk.hpp>
 #include <rapidsmpf/communicator/communicator.hpp>
 #include <rapidsmpf/memory/buffer_resource.hpp>
 #include <rapidsmpf/owning_wrapper.hpp>

cpp/libcudf_streaming/examples/example_shuffle.cpp

@@ -6,6 +6,7 @@
 #include "../benchmarks/utils/random_data.hpp"
 
 #include <cudf_streaming/integrations/partition.hpp>
+
 #include <mpi.h>
 #include <rapidsmpf/communicator/mpi.hpp>
 #include <rapidsmpf/error.hpp>

cpp/libcudf_streaming/include/cudf_streaming/streaming/channel_metadata.hpp

@@ -7,9 +7,10 @@
 
 #include <cudf/types.hpp>
 
+#include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <cuda_runtime_api.h>
 
-#include <cudf_streaming/streaming/table_chunk.hpp>
 #include <rapidsmpf/memory/buffer_resource.hpp>
 #include <rapidsmpf/memory/content_description.hpp>
 #include <rapidsmpf/streaming/core/message.hpp>

cpp/libcudf_streaming/src/integrations/bloom_filter.cu

@@ -32,13 +32,14 @@
 #include <cudf/table/table_view.hpp>
 #include <cudf/utilities/memory_resource.hpp>
 
+#include <cudf_streaming/integrations/bloom_filter.hpp>
+
 #include <rmm/cuda_stream_view.hpp>
 #include <rmm/resource_ref.hpp>
 
 #include <cub/device/device_transform.cuh>
 #include <cuda/std/tuple>
 
-#include <cudf_streaming/integrations/bloom_filter.hpp>
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/error.hpp>
 #include <rapidsmpf/memory/buffer.hpp>

cpp/libcudf_streaming/src/integrations/partition.cpp

@@ -9,11 +9,12 @@
 #include <cudf/types.hpp>
 #include <cudf/utilities/span.hpp>
 
+#include <cudf_streaming/integrations/partition.hpp>
+#include <cudf_streaming/integrations/utils.hpp>
+
 #include <rmm/cuda_stream_view.hpp>
 #include <rmm/device_buffer.hpp>
 
-#include <cudf_streaming/integrations/partition.hpp>
-#include <cudf_streaming/integrations/utils.hpp>
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/error.hpp>
 #include <rapidsmpf/memory/buffer.hpp>

cpp/libcudf_streaming/src/integrations/utils.cpp

@@ -12,6 +12,7 @@
 #include <cudf/wrappers/dictionary.hpp>
 
 #include <cudf_streaming/integrations/utils.hpp>
+
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/error.hpp>
 #include <rapidsmpf/memory/buffer.hpp>

cpp/libcudf_streaming/src/streaming/bloom_filter.cpp

@@ -5,11 +5,12 @@
 
 #include <cudf/stream_compaction.hpp>
 
-#include <cuda_runtime_api.h>
-
 #include <cudf_streaming/integrations/bloom_filter.hpp>
 #include <cudf_streaming/streaming/bloom_filter.hpp>
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
+#include <cuda_runtime_api.h>
+
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/error.hpp>
 #include <rapidsmpf/memory/buffer_resource.hpp>

cpp/libcudf_streaming/src/streaming/channel_metadata.cpp

@@ -9,6 +9,7 @@
 #include <cudf/scalar/scalar.hpp>
 
 #include <cudf_streaming/streaming/channel_metadata.hpp>
+
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/error.hpp>
 #include <rapidsmpf/memory/memory_reservation.hpp>

cpp/libcudf_streaming/src/streaming/parquet.cpp

@@ -9,10 +9,11 @@
 #include <cudf/io/parquet_metadata.hpp>
 #include <cudf/io/types.hpp>
 
-#include <rmm/cuda_stream_view.hpp>
-
 #include <cudf_streaming/streaming/parquet.hpp>
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
+#include <rmm/cuda_stream_view.hpp>
+
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/memory/memory_type.hpp>
 #include <rapidsmpf/statistics.hpp>

cpp/libcudf_streaming/src/streaming/partition.cpp

@@ -7,6 +7,7 @@
 #include <cudf_streaming/integrations/partition.hpp>
 #include <cudf_streaming/streaming/partition.hpp>
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/memory/spill.hpp>
 #include <rapidsmpf/streaming/chunks/partition.hpp>

cpp/libcudf_streaming/src/streaming/table_chunk.cpp

@@ -5,9 +5,10 @@
 
 #include <cudf/contiguous_split.hpp>
 
+#include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rmm/mr/per_device_resource.hpp>
 
-#include <cudf_streaming/streaming/table_chunk.hpp>
 #include <rapidsmpf/cuda_stream.hpp>
 #include <rapidsmpf/memory/buffer.hpp>
 #include <rapidsmpf/statistics.hpp>

cpp/libcudf_streaming/tests/streaming/test_allgather.cpp

@@ -5,10 +5,11 @@
 
 #include "base_streaming_fixture.hpp"
 
+#include <cudf_streaming/integrations/partition.hpp>
+
 #include <cuda_runtime_api.h>
 
 #include <coro/latch.hpp>
-#include <cudf_streaming/integrations/partition.hpp>
 #include <gmock/gmock.h>
 #include <gtest/gtest.h>
 #include <rapidsmpf/communicator/single.hpp>

cpp/libcudf_streaming/tests/streaming/test_channel_metadata.cpp

@@ -9,11 +9,12 @@
 #include <cudf/table/table.hpp>
 #include <cudf/utilities/default_stream.hpp>
 
+#include <cudf_streaming/streaming/channel_metadata.hpp>
+#include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <rmm/cuda_stream_view.hpp>
 #include <rmm/device_buffer.hpp>
 
-#include <cudf_streaming/streaming/channel_metadata.hpp>
-#include <cudf_streaming/streaming/table_chunk.hpp>
 #include <rapidsmpf/memory/buffer_resource.hpp>
 
 #include <memory>

cpp/libcudf_streaming/tests/streaming/test_leaf_actor.cpp

@@ -9,6 +9,7 @@
 #include <cudf_test/table_utilities.hpp>
 
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <gmock/gmock.h>
 #include <gtest/gtest.h>
 #include <rapidsmpf/communicator/single.hpp>

cpp/libcudf_streaming/tests/streaming/test_partition.cpp

@@ -11,6 +11,7 @@
 
 #include <cudf_streaming/streaming/partition.hpp>
 #include <cudf_streaming/streaming/table_chunk.hpp>
+
 #include <gmock/gmock.h>
 #include <rapidsmpf/communicator/single.hpp>
 #include <rapidsmpf/memory/buffer.hpp>