dd

Author: kewang1024

velox/common/file/tests/FaultyFileSystem.cpp

@@ -57,8 +57,8 @@ std::unique_ptr<ReadFile> FaultyFileSystem::openFileForRead(
     std::string_view path,
     const FileOptions& options) {
   const std::string delegatedPath = std::string(extractPath(path));
-  auto delegatedFile = getFileSystem(
-      delegatedPath, config_)->openFileForRead(delegatedPath, options);
+  auto delegatedFile = getFileSystem(delegatedPath, config_)
+                              ->openFileForRead(delegatedPath, options);
   return std::make_unique<FaultyReadFile>(
       std::string(path), std::move(delegatedFile), [&](FaultFileOperation* op) {
         maybeInjectFileFault(op);
@@ -70,7 +70,7 @@ std::unique_ptr<WriteFile> FaultyFileSystem::openFileForWrite(
     const FileOptions& options) {
   const std::string delegatedPath = std::string(extractPath(path));
   auto delegatedFile = getFileSystem(delegatedPath, config_)
-      ->openFileForWrite(delegatedPath, options);
+                                       ->openFileForWrite(delegatedPath, options);
   return std::make_unique<FaultyWriteFile>(
       std::string(path), std::move(delegatedFile), [&](FaultFileOperation* op) {
         maybeInjectFileFault(op);
@@ -115,8 +115,8 @@ std::vector<std::string> FaultyFileSystem::listFolders(std::string_view path) {
   const auto delegatedDirPath = extractPath(path);
   const auto delegatedFolders =
       getFileSystem(delegatedDirPath, config_)->listFolders(delegatedDirPath);
-  // NOTE: we shall return the faulty folder paths instead of the delegated folder
-  // paths for list result.
+  // NOTE: we shall return the faulty folder paths instead of the delegated
+  // folder paths for list result.
   std::vector<std::string> folders;
   folders.reserve(delegatedFolders.size());
   for (const auto& delegateFolder : delegatedFolders) {

velox/exec/fuzzer/PrestoQueryRunner.cpp

@@ -504,13 +504,16 @@ std::optional<std::string> PrestoQueryRunner::toSql(
       std::dynamic_pointer_cast<connector::hive::HiveInsertTableHandle>(
           tableWriteNode->insertTableHandle()->connectorInsertTableHandle());
 
-  // Returns a CREATE sql with specified table properties from TableWriteNode, example sql:
-  // CREATE TABLE tmp_write (c0 integer, c1 varchar, p0 varchar) WITH (PARTITIONED_BY = ARRAY['p0']);
+  // Returns a CREATE sql with specified table properties from TableWriteNode,
+  // example sql:
+  // CREATE TABLE tmp_write (c0 integer, c1 varchar, p0 varchar)
+  // WITH (PARTITIONED_BY = ARRAY['p0']);
   std::stringstream sql;
   sql << "CREATE TABLE tmp_write ( ";
   for (auto i = 0; i < tableWriteNode->columnNames().size(); ++i) {
     appendComma(i, sql);
-    sql << tableWriteNode->columnNames()[i] << " " << toTypeSql(tableWriteNode->columns()->childAt(i));
+    sql << tableWriteNode->columnNames()[i] << " "
+        << toTypeSql(tableWriteNode->columns()->childAt(i));
     if (insertTableHandle->inputColumns()[i]->isPartitionKey()) {
       partitionKeys.push_back(insertTableHandle->inputColumns()[i]->name());
     }