rapids-bot · Jul 7, 2021 · Nov 6, 2020 · Nov 6, 2020 · Nov 6, 2020 · Nov 6, 2020
diff --git a/ci/checks/style.sh b/ci/checks/style.sh
@@ -13,6 +13,10 @@ LANG=C.UTF-8
 # Activate common conda env
 source activate gdf
 
+gpuci_conda_retry remove --force rapids-build-env rapids-notebook-env
+gpuci_conda_retry install -y "clang=11.0.0"
+gpuci_conda_retry install -y "clang-tools=11.0.0"
+
 # Run isort and get results/return code
 ISORT=`isort --check-only python/**/*.py`
 ISORT_RETVAL=$?

diff --git a/conda/environments/cudf_dev_cuda11.0.yml b/conda/environments/cudf_dev_cuda11.0.yml
@@ -7,8 +7,8 @@ channels:
   - rapidsai-nightly
   - conda-forge
 dependencies:
-  - clang=8.0.1
-  - clang-tools=8.0.1
+  - clang=11.0.0
+  - clang-tools=11.0.0
   - cupy>7.1.0,<10.0.0a0
   - rmm=21.08.*
   - cmake>=3.20.1

diff --git a/conda/environments/cudf_dev_cuda11.2.yml b/conda/environments/cudf_dev_cuda11.2.yml
@@ -7,8 +7,8 @@ channels:
   - rapidsai-nightly
   - conda-forge
 dependencies:
-  - clang=8.0.1
-  - clang-tools=8.0.1
+  - clang=11.0.0
+  - clang-tools=11.0.0
   - cupy>7.1.0,<10.0.0a0
   - rmm=21.08.*
   - cmake>=3.20.1

diff --git a/cpp/.clang-format b/cpp/.clang-format
@@ -6,16 +6,22 @@ Language: Cpp
 AccessModifierOffset: -1
 AlignAfterOpenBracket: Align
 AlignConsecutiveAssignments: true
+AlignConsecutiveBitFields: true
 AlignConsecutiveDeclarations: false
+AlignConsecutiveMacros: true
 AlignEscapedNewlines: Left
 AlignOperands: true
 AlignTrailingComments: true
+AllowAllArgumentsOnNextLine: true
+AllowAllConstructorInitializersOnNextLine: true
 AllowAllParametersOfDeclarationOnNextLine: true
 AllowShortBlocksOnASingleLine: true 
 AllowShortCaseLabelsOnASingleLine: true
+AllowShortEnumsOnASingleLine: true
 AllowShortFunctionsOnASingleLine: All
 AllowShortIfStatementsOnASingleLine: true
-AllowShortLoopsOnASingleLine: true
+AllowShortLambdasOnASingleLine: true
+AllowShortLoopsOnASingleLine: false
 # This is deprecated
 AlwaysBreakAfterDefinitionReturnType: None
 AlwaysBreakAfterReturnType: None
@@ -40,14 +46,15 @@ BraceWrapping:
   SplitEmptyFunction: false
   SplitEmptyRecord: false
   SplitEmptyNamespace: false
+BreakAfterJavaFieldAnnotations: false
 BreakBeforeBinaryOperators: None
 BreakBeforeBraces: WebKit
 BreakBeforeInheritanceComma: false
-BreakInheritanceList: BeforeColon
+BreakBeforeTernaryOperators: true
 BreakBeforeTernaryOperators: true
 BreakConstructorInitializersBeforeComma: false
 BreakConstructorInitializers: BeforeColon
-BreakAfterJavaFieldAnnotations: false
+BreakInheritanceList: BeforeColon
 BreakStringLiterals: true
 ColumnLimit: 100
 CommentPragmas: '^ IWYU pragma:'
@@ -57,7 +64,7 @@ ConstructorInitializerAllOnOneLineOrOnePerLine: true
 ConstructorInitializerIndentWidth: 2
 ContinuationIndentWidth: 2
 Cpp11BracedListStyle: true
-DerivePointerAlignment: true
+DerivePointerAlignment: false
 DisableFormat: false
 ExperimentalAutoDetectBinPacking: false
 FixNamespaceComments: true
@@ -139,14 +146,17 @@ SpaceBeforeCtorInitializerColon: true
 SpaceBeforeInheritanceColon: true
 SpaceBeforeParens: ControlStatements
 SpaceBeforeRangeBasedForLoopColon: true
+SpaceBeforeSquareBrackets: false
+SpaceInEmptyBlock: false
 SpaceInEmptyParentheses: false
 SpacesBeforeTrailingComments: 2
 SpacesInAngles: false
+SpacesInConditionalStatement: false
 SpacesInContainerLiterals: true
 SpacesInCStyleCastParentheses: false
 SpacesInParentheses: false
 SpacesInSquareBrackets: false
-Standard: Cpp11
+Standard: c++17
 StatementMacros:
   - Q_UNUSED
   - QT_REQUIRE_VERSION

diff --git a/cpp/benchmarks/ast/transform_benchmark.cpp b/cpp/benchmarks/ast/transform_benchmark.cpp
@@ -135,7 +135,9 @@ static void CustomRanges(benchmark::internal::Benchmark* b)
   auto row_counts       = std::vector<cudf::size_type>{100'000, 1'000'000, 10'000'000, 100'000'000};
   auto operation_counts = std::vector<cudf::size_type>{1, 5, 10};
   for (auto const& row_count : row_counts) {
-    for (auto const& operation_count : operation_counts) { b->Args({row_count, operation_count}); }
+    for (auto const& operation_count : operation_counts) {
+      b->Args({row_count, operation_count});
+    }
   }
 }
 

diff --git a/cpp/benchmarks/binaryop/binaryop_benchmark.cpp b/cpp/benchmarks/binaryop/binaryop_benchmark.cpp
@@ -113,7 +113,9 @@ static void CustomRanges(benchmark::internal::Benchmark* b)
   auto row_counts       = std::vector<cudf::size_type>{100'000, 1'000'000, 10'000'000, 100'000'000};
   auto operation_counts = std::vector<cudf::size_type>{1, 2, 5, 10};
   for (auto const& row_count : row_counts) {
-    for (auto const& operation_count : operation_counts) { b->Args({row_count, operation_count}); }
+    for (auto const& operation_count : operation_counts) {
+      b->Args({row_count, operation_count});
+    }
   }
 }
 

diff --git a/cpp/benchmarks/common/generate_benchmark_input.cpp b/cpp/benchmarks/common/generate_benchmark_input.cpp
@@ -53,7 +53,7 @@ T get_distribution_mean(distribution_params<T> const& dist)
       auto const range_size = dist.lower_bound < dist.upper_bound
                                 ? dist.upper_bound - dist.lower_bound
                                 : dist.lower_bound - dist.upper_bound;
-      auto const p = geometric_dist_p(range_size);
+      auto const p          = geometric_dist_p(range_size);
       if (dist.lower_bound < dist.upper_bound)
         return dist.lower_bound + (1. / p);
       else

diff --git a/cpp/benchmarks/hashing/partition_benchmark.cpp b/cpp/benchmarks/hashing/partition_benchmark.cpp
@@ -65,7 +65,9 @@ static void CustomRanges(benchmark::internal::Benchmark* b)
 {
   for (int columns = 1; columns <= 256; columns *= 16) {
     for (int partitions = 64; partitions <= 1024; partitions *= 2) {
-      for (int rows = 1 << 17; rows <= 1 << 21; rows *= 2) { b->Args({rows, columns, partitions}); }
+      for (int rows = 1 << 17; rows <= 1 << 21; rows *= 2) {
+        b->Args({rows, columns, partitions});
+      }
     }
   }
 }

diff --git a/cpp/benchmarks/io/cuio_benchmark_common.cpp b/cpp/benchmarks/io/cuio_benchmark_common.cpp
@@ -94,7 +94,8 @@ std::vector<int> select_column_indexes(int num_cols, column_selection col_sel)
                 (col_sel == column_selection::SECOND_HALF) ? num_cols / 2 : 0);
       break;
     case column_selection::ALTERNATE:
-      for (size_t i = 0; i < col_idxs.size(); ++i) col_idxs[i] = 2 * i;
+      for (size_t i = 0; i < col_idxs.size(); ++i)
+        col_idxs[i] = 2 * i;
       break;
   }
   return col_idxs;

diff --git a/cpp/benchmarks/iterator/iterator_benchmark.cu b/cpp/benchmarks/iterator/iterator_benchmark.cu
@@ -61,7 +61,7 @@ inline auto reduce_by_cub(OutputIterator result, InputIterator d_in, int num_ite
 
 // -----------------------------------------------------------------------------
 template <typename T>
-void raw_stream_bench_cub(cudf::column_view &col, rmm::device_uvector<T> &result)
+void raw_stream_bench_cub(cudf::column_view& col, rmm::device_uvector<T>& result)
 {
   // std::cout << "raw stream cub: " << "\t";
 
@@ -73,7 +73,7 @@ void raw_stream_bench_cub(cudf::column_view &col, rmm::device_uvector<T> &result
 };
 
 template <typename T, bool has_null>
-void iterator_bench_cub(cudf::column_view &col, rmm::device_uvector<T> &result)
+void iterator_bench_cub(cudf::column_view& col, rmm::device_uvector<T>& result)
 {
   // std::cout << "iterator cub " << ( (has_null) ? "<true>: " : "<false>: " ) << "\t";
 
@@ -91,7 +91,7 @@ void iterator_bench_cub(cudf::column_view &col, rmm::device_uvector<T> &result)
 
 // -----------------------------------------------------------------------------
 template <typename T>
-void raw_stream_bench_thrust(cudf::column_view &col, rmm::device_uvector<T> &result)
+void raw_stream_bench_thrust(cudf::column_view& col, rmm::device_uvector<T>& result)
 {
   // std::cout << "raw stream thust: " << "\t\t";
 
@@ -102,7 +102,7 @@ void raw_stream_bench_thrust(cudf::column_view &col, rmm::device_uvector<T> &res
 }
 
 template <typename T, bool has_null>
-void iterator_bench_thrust(cudf::column_view &col, rmm::device_uvector<T> &result)
+void iterator_bench_thrust(cudf::column_view& col, rmm::device_uvector<T>& result)
 {
   // std::cout << "iterator thust " << ( (has_null) ? "<true>: " : "<false>: " ) << "\t";
 
@@ -124,7 +124,7 @@ class Iterator : public cudf::benchmark {
 };
 
 template <class TypeParam, bool cub_or_thrust, bool raw_or_iterator>
-void BM_iterator(benchmark::State &state)
+void BM_iterator(benchmark::State& state)
 {
   const cudf::size_type column_size{(cudf::size_type)state.range(0)};
   using T      = TypeParam;
@@ -165,8 +165,8 @@ __device__ thrust::pair<T, bool> operator+(thrust::pair<T, bool> lhs, thrust::pa
 }
 // -----------------------------------------------------------------------------
 template <typename T, bool has_null>
-void pair_iterator_bench_cub(cudf::column_view &col,
-                             rmm::device_uvector<thrust::pair<T, bool>> &result)
+void pair_iterator_bench_cub(cudf::column_view& col,
+                             rmm::device_uvector<thrust::pair<T, bool>>& result)
 {
   thrust::pair<T, bool> init{0, false};
   auto d_col    = cudf::column_device_view::create(col);
@@ -176,8 +176,8 @@ void pair_iterator_bench_cub(cudf::column_view &col,
 }
 
 template <typename T, bool has_null>
-void pair_iterator_bench_thrust(cudf::column_view &col,
-                                rmm::device_uvector<thrust::pair<T, bool>> &result)
+void pair_iterator_bench_thrust(cudf::column_view& col,
+                                rmm::device_uvector<thrust::pair<T, bool>>& result)
 {
   thrust::pair<T, bool> init{0, false};
   auto d_col = cudf::column_device_view::create(col);
@@ -187,7 +187,7 @@ void pair_iterator_bench_thrust(cudf::column_view &col,
 }
 
 template <class TypeParam, bool cub_or_thrust>
-void BM_pair_iterator(benchmark::State &state)
+void BM_pair_iterator(benchmark::State& state)
 {
   const cudf::size_type column_size{(cudf::size_type)state.range(0)};
   using T      = TypeParam;

diff --git a/cpp/benchmarks/reduction/anyall_benchmark.cpp b/cpp/benchmarks/reduction/anyall_benchmark.cpp
@@ -48,7 +48,7 @@ void BM_reduction_anyall(benchmark::State& state, std::unique_ptr<cudf::aggregat
 }
 
 #define concat(a, b, c) a##b##c
-#define get_agg(op) concat(cudf::make_, op, _aggregation())
+#define get_agg(op)     concat(cudf::make_, op, _aggregation())
 
 // TYPE, OP
 #define RBM_BENCHMARK_DEFINE(name, type, aggregation)             \

diff --git a/cpp/benchmarks/reduction/dictionary_benchmark.cpp b/cpp/benchmarks/reduction/dictionary_benchmark.cpp
@@ -53,7 +53,7 @@ void BM_reduction_dictionary(benchmark::State& state, std::unique_ptr<cudf::aggr
 }
 
 #define concat(a, b, c) a##b##c
-#define get_agg(op) concat(cudf::make_, op, _aggregation())
+#define get_agg(op)     concat(cudf::make_, op, _aggregation())
 
 // TYPE, OP
 #define RBM_BENCHMARK_DEFINE(name, type, aggregation)                       \

diff --git a/cpp/benchmarks/reduction/minmax_benchmark.cpp b/cpp/benchmarks/reduction/minmax_benchmark.cpp
@@ -48,7 +48,7 @@ void BM_reduction(benchmark::State& state)
 }
 
 #define concat(a, b, c) a##b##c
-#define get_agg(op) concat(cudf::make_, op, _aggregation())
+#define get_agg(op)     concat(cudf::make_, op, _aggregation())
 
 // TYPE, OP
 #define RBM_BENCHMARK_DEFINE(name, type, aggregation)                                            \

diff --git a/cpp/benchmarks/reduction/reduce_benchmark.cpp b/cpp/benchmarks/reduction/reduce_benchmark.cpp
@@ -54,7 +54,7 @@ void BM_reduction(benchmark::State& state, std::unique_ptr<cudf::aggregation> co
 }
 
 #define concat(a, b, c) a##b##c
-#define get_agg(op) concat(cudf::make_, op, _aggregation())
+#define get_agg(op)     concat(cudf::make_, op, _aggregation())
 
 // TYPE, OP
 #define RBM_BENCHMARK_DEFINE(name, type, aggregation)             \

diff --git a/cpp/benchmarks/search/search_benchmark.cpp b/cpp/benchmarks/search/search_benchmark.cpp
@@ -131,7 +131,8 @@ BENCHMARK_DEFINE_F(Search, Table)(::benchmark::State& state) { BM_table(state);
 static void CustomArguments(benchmark::internal::Benchmark* b)
 {
   for (int num_cols = 1; num_cols <= 10; num_cols *= 2)
-    for (int col_size = 1000; col_size <= 100000000; col_size *= 10) b->Args({num_cols, col_size});
+    for (int col_size = 1000; col_size <= 100000000; col_size *= 10)
+      b->Args({num_cols, col_size});
 }
 
 BENCHMARK_REGISTER_F(Search, Table)

diff --git a/cpp/benchmarks/stream_compaction/apply_boolean_mask_benchmark.cpp b/cpp/benchmarks/stream_compaction/apply_boolean_mask_benchmark.cpp
@@ -35,13 +35,15 @@ constexpr cudf::size_type fifty_percent = 50;
 void percent_range(benchmark::internal::Benchmark* b)
 {
   b->Unit(benchmark::kMillisecond);
-  for (int percent = 0; percent <= 100; percent += 10) b->Args({hundredM, percent});
+  for (int percent = 0; percent <= 100; percent += 10)
+    b->Args({hundredM, percent});
 }
 
 void size_range(benchmark::internal::Benchmark* b)
 {
   b->Unit(benchmark::kMillisecond);
-  for (int size = tenK; size <= hundredM; size *= 10) b->Args({size, fifty_percent});
+  for (int size = tenK; size <= hundredM; size *= 10)
+    b->Args({size, fifty_percent});
 }
 
 template <typename T>
@@ -64,9 +66,9 @@ void calculate_bandwidth(benchmark::State& state, cudf::size_type num_columns)
   cudf::size_type const column_size_out = fraction * column_size;
   int64_t const mask_size =
     sizeof(bool) * column_size + cudf::bitmask_allocation_size_bytes(column_size);
-  int64_t const validity_bytes_in = (fraction >= 1.0f / 32)
-                                      ? cudf::bitmask_allocation_size_bytes(column_size)
-                                      : 4 * column_size_out;
+  int64_t const validity_bytes_in  = (fraction >= 1.0f / 32)
+                                       ? cudf::bitmask_allocation_size_bytes(column_size)
+                                       : 4 * column_size_out;
   int64_t const validity_bytes_out = cudf::bitmask_allocation_size_bytes(column_size_out);
   int64_t const column_bytes_out   = sizeof(T) * column_size_out;
   int64_t const column_bytes_in    = column_bytes_out;  // we only read unmasked inputs

diff --git a/cpp/benchmarks/stream_compaction/drop_duplicates_benchmark.cpp b/cpp/benchmarks/stream_compaction/drop_duplicates_benchmark.cpp
@@ -50,7 +50,7 @@ void BM_compaction(benchmark::State& state, cudf::duplicate_keep_option keep)
 }
 
 #define concat(a, b, c) a##b##c
-#define get_keep(op) cudf::duplicate_keep_option::KEEP_##op
+#define get_keep(op)    cudf::duplicate_keep_option::KEEP_##op
 
 // TYPE, OP
 #define RBM_BENCHMARK_DEFINE(name, type, keep)                     \

diff --git a/cpp/benchmarks/string/extract_benchmark.cpp b/cpp/benchmarks/string/extract_benchmark.cpp
@@ -48,7 +48,9 @@ static void BM_extract(benchmark::State& state, int groups)
   });
 
   std::string pattern;
-  while (static_cast<int>(pattern.size()) < groups) { pattern += "(\\d+) "; }
+  while (static_cast<int>(pattern.size()) < groups) {
+    pattern += "(\\d+) ";
+  }
 
   std::uniform_int_distribution<int> distribution(0, samples.size() - 1);
   auto elements = cudf::detail::make_counting_transform_iterator(

diff --git a/cpp/benchmarks/text/replace_benchmark.cpp b/cpp/benchmarks/text/replace_benchmark.cpp
@@ -41,7 +41,8 @@ static void BM_replace(benchmark::State& state)
   std::default_random_engine generator;
   std::uniform_int_distribution<int> tokens_dist(0, words.size() - 1);
   std::string row;  // build a row of random tokens
-  while (static_cast<int>(row.size()) < n_length) row += words[tokens_dist(generator)];
+  while (static_cast<int>(row.size()) < n_length)
+    row += words[tokens_dist(generator)];
 
   std::uniform_int_distribution<int> position_dist(0, 16);
 

diff --git a/cpp/benchmarks/text/subword_benchmark.cpp b/cpp/benchmarks/text/subword_benchmark.cpp
@@ -37,15 +37,17 @@ static std::string create_hash_vocab_file()
   std::vector<std::pair<int, int>> coefficients(23, {65559, 0});
   std::ofstream outfile(hash_file, std::ofstream::out);
   outfile << "1\n0\n" << coefficients.size() << "\n";
-  for (auto c : coefficients) outfile << c.first << " " << c.second << "\n";
+  for (auto c : coefficients)
+    outfile << c.first << " " << c.second << "\n";
   std::vector<uint64_t> hash_table(23, 0);
   outfile << hash_table.size() << "\n";
   hash_table[0]  = 3015668L;
   hash_table[1]  = 6205475701751155871L;
   hash_table[5]  = 6358029;
   hash_table[16] = 451412625363L;
   hash_table[20] = 6206321707968235495L;
-  for (auto h : hash_table) outfile << h << "\n";
+  for (auto h : hash_table)
+    outfile << h << "\n";
   outfile << "100\n101\n102\n\n";
   return hash_file;
 }

diff --git a/cpp/benchmarks/type_dispatcher/type_dispatcher_benchmark.cu b/cpp/benchmarks/type_dispatcher/type_dispatcher_benchmark.cu
@@ -64,7 +64,9 @@ __global__ void no_dispatching_kernel(T** A, cudf::size_type n_rows, cudf::size_
   using F               = Functor<T, functor_type>;
   cudf::size_type index = blockIdx.x * blockDim.x + threadIdx.x;
   while (index < n_rows) {
-    for (int c = 0; c < n_cols; c++) { A[c][index] = F::f(A[c][index]); }
+    for (int c = 0; c < n_cols; c++) {
+      A[c][index] = F::f(A[c][index]);
+    }
     index += blockDim.x * gridDim.x;
   }
 }

diff --git a/cpp/include/cudf/detail/copy_if_else.cuh b/cpp/include/cudf/detail/copy_if_else.cuh
@@ -46,7 +46,7 @@ __launch_bounds__(block_size) __global__
                            RightIter rhs,
                            Filter filter,
                            mutable_column_device_view out,
-                           size_type *__restrict__ const valid_count)
+                           size_type* __restrict__ const valid_count)
 {
   const size_type tid            = threadIdx.x + blockIdx.x * block_size;
   const int warp_id              = tid / warp_size;
@@ -166,7 +166,7 @@ std::unique_ptr<column> copy_if_else(
   FilterFn filter,
   cudf::data_type output_type,
   rmm::cuda_stream_view stream,
-  rmm::mr::device_memory_resource *mr = rmm::mr::get_current_device_resource())
+  rmm::mr::device_memory_resource* mr = rmm::mr::get_current_device_resource())
 {
   using Element =
     typename thrust::tuple_element<0, typename thrust::iterator_traits<LeftIter>::value_type>::type;