fix Init

velox/benchmarks/basic/ComparisonConjunct.cpp

@@ -175,7 +175,7 @@ BENCHMARK(conjunctsNested) {
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   memory::MemoryManager::initialize({});
   benchmark = std::make_unique<ComparisonBenchmark>(1'000);

velox/benchmarks/basic/DecodedVector.cpp

@@ -188,7 +188,7 @@ BENCHMARK(decodeDictionary5Nested) {
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   memory::MemoryManager::initialize({});
   benchmark = std::make_unique<DecodedVectorBenchmark>(10'000);

velox/benchmarks/basic/FeatureNormalization.cpp

@@ -110,7 +110,7 @@ BENCHMARK(normalizeConstant) {
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   memory::MemoryManager::initialize({});
   benchmark = std::make_unique<FeatureNormailzationBenchmark>();

velox/benchmarks/basic/LikeTpchBenchmark.cpp

@@ -242,7 +242,7 @@ BENCHMARK(tpchQuery20) {
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv, true);
+  folly::Init init{&argc, &argv, true};
   memory::MemoryManager::initialize({});
   benchmark = std::make_unique<LikeFunctionsBenchmark>();
   folly::runBenchmarks();

velox/benchmarks/basic/Preproc.cpp

@@ -444,7 +444,7 @@ BENCHMARK(allFusedWithNulls) {
 } // namespace
 
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   memory::MemoryManager::initialize({});
   benchmark = std::make_unique<PreprocBenchmark>();
   // Verify that benchmark calculations are correct.

velox/benchmarks/basic/SelectivityVector.cpp

@@ -164,7 +164,7 @@ BENCHMARK(sumSelectivity1PerCent) {
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   memory::MemoryManager::initialize({});
   benchmark = std::make_unique<SelectivityVectorBenchmark>(10'000);

velox/benchmarks/basic/SimpleArithmetic.cpp

@@ -343,7 +343,7 @@ BENCHMARK(plusCheckedLarge) {
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   memory::MemoryManager::initialize({});
   benchmark = std::make_unique<SimpleArithmeticBenchmark>();

velox/benchmarks/basic/SimpleCastExpr.cpp

@@ -250,7 +250,7 @@ BENCHMARK(castStructManyFieldsNestedCastMedium) {
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   memory::MemoryManager::initialize({});
   benchmark = std::make_unique<SimpleCastBenchmark>();

velox/benchmarks/basic/VectorCompare.cpp

@@ -114,7 +114,7 @@ BENCHMARK_DRAW_LINE();
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   memory::MemoryManager::initialize({});
   benchmark = std::make_unique<VectorCompareBenchmark>(1000);

velox/benchmarks/basic/VectorFuzzer.cpp

@@ -131,7 +131,7 @@ BENCHMARK_RELATIVE_MULTI(flatMapArrayNested, n) {
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   memory::MemoryManager::initialize({});
   folly::runBenchmarks();

velox/benchmarks/basic/VectorSlice.cpp

@@ -110,7 +110,7 @@ DEFINE_BENCHMARKS(row)
 } // namespace facebook::velox
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   using namespace facebook::velox;
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   VELOX_CHECK_LE(FLAGS_slice_size, kVectorSize);

velox/benchmarks/tpch/TpchBenchmarkMain.cpp

@@ -23,6 +23,6 @@ int main(int argc, char** argv) {
   std::string kUsage(
       "This program benchmarks TPC-H queries. Run 'velox_tpch_benchmark -helpon=TpchBenchmark' for available options.\n");
   gflags::SetUsageMessage(kUsage);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   tpchBenchmarkMain();
 }

velox/benchmarks/unstable/MemoryAllocationBenchmark.cpp

@@ -435,7 +435,7 @@ BENCHMARK_RELATIVE_MULTI(MmapReallocateMix64) {
 } // namespace
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   // TODO: add to run benchmark as a standalone program with multithreading as
   // well as actual memory access to trigger minor page faults in OS which traps
   // into kernel context to setup physical pages for the lazy-mapped virtual

velox/common/base/benchmarks/BitUtilBenchmark.cpp

@@ -191,7 +191,7 @@ BENCHMARK_RELATIVE_MULTI(forEachBitFirstBitFalse) {
 } // namespace facebook
 
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   folly::runBenchmarks();
   return 0;
 }

velox/common/base/tests/Memcpy.cpp

@@ -58,7 +58,7 @@ struct CopyCallable {
 
 int main(int argc, char** argv) {
   constexpr int32_t kAlignment = folly::hardware_destructive_interference_size;
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   auto chunk = bits::roundUp(
       std::max<int64_t>(FLAGS_bytes / FLAGS_threads, kAlignment), kAlignment);
   int64_t bytes = chunk * FLAGS_threads;

velox/common/base/tests/StatsReporterTest.cpp

@@ -134,7 +134,7 @@ folly::Singleton<BaseStatsReporter> reporter([]() {
 
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   facebook::velox::BaseStatsReporter::registered = true;
   return RUN_ALL_TESTS();
 }

velox/common/file/benchmark/ReadBenchmarkMain.cpp

@@ -24,7 +24,7 @@ using namespace facebook::velox;
 // and the IO throughput is 100 MBps, then it takes 10 seconds to just read the
 // data.
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   ReadBenchmark bm;
   bm.initialize();
   bm.run();

velox/common/memory/tests/MemoryPoolBenchmark.cpp

@@ -239,7 +239,7 @@ BENCHMARK(FlatSticks, iters) {
 }
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   folly::runBenchmarks();
   return 0;
 }

velox/common/process/ThreadDebugInfo.h

@@ -47,7 +47,7 @@ const ThreadDebugInfo* GetThreadDebugInfo();
 
 // Install a signal handler to dump thread local debug information. This should
 // be called before calling folly::symbolizer::installFatalSignalCallbacks()
-// which is usually called at startup via folly::Init(). This is just a default
+// which is usually called at startup via folly::Init init{}. This is just a default
 // implementation but you can install your own signal handler. Make sure to
 // install one at the start of your program.
 void addDefaultFatalSignalHandler();

velox/connectors/hive/benchmarks/HivePartitionFunctionBenchmark.cpp

@@ -329,7 +329,7 @@ BENCHMARK_DRAW_LINE();
 } // namespace
 
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   gflags::ParseCommandLineFlags(&argc, &argv, true);
   memory::MemoryManager::initialize({});
   benchmarkFew = std::make_unique<HivePartitionFunctionBenchmark>(1'000);

velox/connectors/hive/storage_adapters/gcs/benchmark/GCSReadBenchmarkMain.cpp

@@ -24,7 +24,7 @@ using namespace facebook::velox;
 // and the IO throughput is 100 MBps, then it takes 10 seconds to just read the
 // data.
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   GCSReadBenchmark bm;
   bm.initialize();
   bm.run();

velox/connectors/hive/storage_adapters/s3fs/benchmark/S3ReadBenchmarkMain.cpp

@@ -24,7 +24,7 @@ using namespace facebook::velox;
 // and the IO throughput is 100 MBps, then it takes 10 seconds to just read the
 // data.
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   S3ReadBenchmark bm;
   bm.initialize();
   bm.run();

velox/connectors/hive/storage_adapters/s3fs/tests/S3InsertTest.cpp

@@ -119,6 +119,6 @@ TEST_F(S3InsertTest, s3InsertTest) {
 
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/connectors/hive/storage_adapters/s3fs/tests/S3MultipleEndpointsTest.cpp

@@ -174,6 +174,6 @@ TEST_F(S3MultipleEndpoints, s3Join) {
 
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/connectors/hive/storage_adapters/s3fs/tests/S3ReadTest.cpp

@@ -90,6 +90,6 @@ TEST_F(S3ReadTest, s3ReadTest) {
 
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/connectors/hive/tests/HiveDataSinkTest.cpp

@@ -906,6 +906,6 @@ int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
   // Signal handler required for ThreadDebugInfoTest
   facebook::velox::process::addDefaultFatalSignalHandler();
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/connectors/tpch/tests/SpeedTest.cpp

@@ -180,7 +180,7 @@ class TpchSpeedTest {
 } // namespace
 
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
 
   TpchSpeedTest speedTest;
   speedTest.run(

velox/connectors/tpch/tests/TpchConnectorTest.cpp

@@ -290,6 +290,6 @@ TEST_F(TpchConnectorTest, orderDateCount) {
 
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/dwio/common/tests/BitPackDecoderBenchmark.cpp

@@ -593,7 +593,7 @@ void naiveDecodeBitsLE(
 }
 
 int32_t main(int32_t argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
 
   // Populate uint32 buffer
 

velox/dwio/common/tests/DataBufferBenchmark.cpp

@@ -53,7 +53,7 @@ BENCHMARK(ChainedBufferOps, iters) {
 }
 
 int main(int argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   folly::runBenchmarks();
   facebook::velox::memory::MemoryManager::initialize({});
   return 0;

velox/dwio/common/tests/IntDecoderBenchmark.cpp

@@ -939,7 +939,7 @@ BENCHMARK_RELATIVE(decodeNew_64) {
 }
 
 int32_t main(int32_t argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
 
   // Populate uint16 buffer
   buffer_u16.resize(kNumElements);

velox/dwio/dwrf/test/E2EFilterTest.cpp

@@ -453,6 +453,6 @@ TEST_F(E2EFilterTest, mutationCornerCases) {
 // Define main so that gflags get processed.
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/dwio/dwrf/test/FloatColumnWriterBenchmark.cpp

@@ -129,7 +129,7 @@ BENCHMARK(FloatColumnWriterBenchmark10000) {
 }
 
 int32_t main(int32_t argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   memory::MemoryManager::initialize({});
   folly::runBenchmarks();
   return 0;

velox/dwio/dwrf/test/IntEncoderBenchmark.cpp

@@ -204,7 +204,7 @@ BENCHMARK_RELATIVE(GenerateAutoIdNew_64) {
 }
 
 int32_t main(int32_t argc, char* argv[]) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   memory::MemoryManager::initialize({});
   folly::runBenchmarks();
   return 0;

velox/dwio/parquet/tests/ParquetTpchTest.cpp

@@ -248,6 +248,6 @@ TEST_F(ParquetTpchTest, Q22) {
 
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/dwio/parquet/tests/reader/E2EFilterTest.cpp

@@ -683,6 +683,6 @@ TEST_F(E2EFilterTest, configurableWriteSchema) {
 // Define main so that gflags get processed.
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/dwio/parquet/tests/reader/ParquetReaderBenchmark.cpp

@@ -404,7 +404,7 @@ PARQUET_BENCHMARKS_NO_FILTER(ARRAY(BIGINT()), List);
 // TODO: Add all data types
 
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   memory::MemoryManager::initialize({});
   folly::runBenchmarks();
   return 0;

velox/dwio/parquet/tests/reader/ParquetTableScanTest.cpp

@@ -445,6 +445,6 @@ TEST_F(ParquetTableScanTest, readAsLowerCase) {
 
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/dwio/parquet/tests/thrift/ThriftTransportTest.cpp

@@ -106,6 +106,6 @@ TEST_F(ThriftTransportTest, bufferedOutOfBoundry) {
 // Define main so that gflags get processed.
 int main(int argc, char** argv) {
   testing::InitGoogleTest(&argc, argv);
-  folly::init(&argc, &argv, false);
+  folly::Init init{&argc, &argv, false};
   return RUN_ALL_TESTS();
 }

velox/examples/OperatorExtensibility.cpp

@@ -160,7 +160,7 @@ class DuplicateRowTranslator : public exec::Operator::PlanNodeTranslator {
 };
 
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
 
   // Fourth, we register the custom plan translator. We're now ready to use our
   // operator in a query plan.

velox/examples/ScanAndSort.cpp

@@ -42,7 +42,7 @@ using exec::test::HiveConnectorTestBase;
 int main(int argc, char** argv) {
   // Velox Tasks/Operators are based on folly's async framework, so we need to
   // make sure we initialize it first.
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
 
   // Default memory allocator used throughout this example.
   memory::MemoryManager::initialize({});

velox/examples/ScanOrc.cpp

@@ -31,7 +31,7 @@ using namespace facebook::velox::dwrf;
 // Used to compare the ORC data read by DWRFReader against apache-orc repo.
 // Usage: velox_example_scan_orc {orc_file_path}
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
 
   if (argc < 2) {
     return 1;

velox/exec/benchmarks/ExchangeBenchmark.cpp

@@ -384,7 +384,7 @@ BENCHMARK(localFlat10k) {
 } // namespace
 
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   memory::MemoryManager::initialize({});
   functions::prestosql::registerAllScalarFunctions();
   aggregate::prestosql::registerAllAggregateFunctions();

velox/exec/benchmarks/FilterProjectBenchmark.cpp

@@ -266,7 +266,7 @@ class FilterProjectBenchmark : public VectorTestBase {
 } // namespace
 
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   functions::prestosql::registerAllScalarFunctions();
   aggregate::prestosql::registerAllAggregateFunctions();
   parse::registerTypeResolver();

velox/exec/benchmarks/HashTableBenchmark.cpp

@@ -612,7 +612,7 @@ void combineResults(
 } // namespace
 
 int main(int argc, char** argv) {
-  folly::init(&argc, &argv);
+  folly::Init init{&argc, &argv};
   memory::MemoryManagerOptions options;
   options.useMmapAllocator = true;
   options.allocatorCapacity = 10UL << 30;