Skip to content

Commit

Permalink
Fix build errors
Browse files Browse the repository at this point in the history
Fix format
  • Loading branch information
SurbhiVijayvargeeya committed Jun 1, 2024
1 parent 6aad15c commit ed35a5e
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -94,9 +94,8 @@ class AbfsReadFile::Impl {
fileClient_ = BlobClientProviderFactory::getBlobClient(path_, abfsAccount);
}

void initialize(const FileOptions& options) {
void initialize() {
if (eTag_.empty() || length_ == -1) {

try {
VLOG(1) << "Fetching properties from remote file system for " << path_;
auto properties = fileClient_->GetProperties();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ class AbfsFileSystemTest : public testing::Test {
azuriteServer = std::make_shared<filesystems::test::AzuriteServer>(port);
azuriteServer->start();
auto tempFile = createFile();
azuriteServer->addFile(tempFile->path, filePath);
azuriteServer->addFile(tempFile->getPath(), filePath);
auto connectionStringProvider =
std::make_shared<ConnectionStringBlobClientProvider>(
facebook::velox::filesystems::test::AzuriteAccountName,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -78,7 +78,7 @@ class VegasFileSystemTest : public testing::Test {
static_cast<int64_t>(stoi(port_)));
azuriteServer_->start();
auto tempFile = createFile();
azuriteServer_->addFile(tempFile->path, filePath);
azuriteServer_->addFile(tempFile->getPath(), filePath);
auto connectionStringProvider =
std::make_shared<ConnectionStringBlobClientProvider>(
facebook::velox::filesystems::test::AzuriteAccountName,
Expand Down Expand Up @@ -209,7 +209,7 @@ TEST_F(VegasFileSystemTest, readFileWithPartialOverlaps) {
const std::string fullPath =
facebook::velox::filesystems::test::AzuriteABFSEndpoint + path;
auto tempFile = VegasFileSystemTest::createFile();
azuriteServer_->addFile(tempFile->path, path);
azuriteServer_->addFile(tempFile->getPath(), path);

auto config = VegasFileSystemTest::hiveConfig();
auto abfs = filesystems::getFileSystem(fullPath, config);
Expand Down Expand Up @@ -307,7 +307,7 @@ TEST_F(VegasFileSystemTest, readFileWithJournalDelete) {
const std::string fullPath =
facebook::velox::filesystems::test::AzuriteABFSEndpoint + path;
auto tempFile = VegasFileSystemTest::createFile();
azuriteServer_->addFile(tempFile->path, path);
azuriteServer_->addFile(tempFile->getPath(), path);

auto config = VegasFileSystemTest::hiveConfig();
auto abfs = filesystems::getFileSystem(fullPath, config);
Expand Down Expand Up @@ -338,7 +338,7 @@ TEST_F(VegasFileSystemTest, readFileWithMapDelete) {
const std::string fullPath =
facebook::velox::filesystems::test::AzuriteABFSEndpoint + path;
auto tempFile = VegasFileSystemTest::createFile();
azuriteServer_->addFile(tempFile->path, path);
azuriteServer_->addFile(tempFile->getPath(), path);

auto config = VegasFileSystemTest::hiveConfig();
auto abfs = filesystems::getFileSystem(fullPath, config);
Expand Down Expand Up @@ -371,7 +371,7 @@ TEST_F(VegasFileSystemTest, readFileSemaphoreAlreadyExists) {
const std::string fullPath =
facebook::velox::filesystems::test::AzuriteABFSEndpoint + path;
auto tempFile = VegasFileSystemTest::createFile();
azuriteServer_->addFile(tempFile->path, path);
azuriteServer_->addFile(tempFile->getPath(), path);

unsigned char md5output[MD5_DIGEST_LENGTH];
MD5(reinterpret_cast<const unsigned char*>(fullPath.c_str()),
Expand Down
4 changes: 2 additions & 2 deletions velox/experimental/wave/common/tests/BlockTest.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -155,8 +155,8 @@ class BlockTest : public testing::Test {
}
stream.wait();
elapsed = getCurrentTimeMicro() - startMicros;
std::cout << "Flags " << (use256 ? "256" : "")
<< " to indices: " << " to indices no smem: " << elapsed << "us, "
std::cout << "Flags " << (use256 ? "256" : "") << " to indices: "
<< " to indices no smem: " << elapsed << "us, "
<< kNumFlags / static_cast<float>(elapsed) << " Mrows/s"
<< std::endl;
}
Expand Down

0 comments on commit ed35a5e

Please sign in to comment.