Skip to content

Commit 43e57ef

Browse files
committed
fix pre commit 0612
1 parent aadda0b commit 43e57ef

File tree

6 files changed

+20
-12
lines changed

6 files changed

+20
-12
lines changed

src/paimon/common/lookup/sort/sort_lookup_store_test.cpp

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,10 @@ TEST(SortLookupStoreTest, TestSimple) {
4141
arrow::schema(key_type->fields()), pool));
4242
ASSERT_OK_AND_ASSIGN(CoreOptions options, CoreOptions::FromMap(options_map));
4343

44-
ASSERT_OK_AND_ASSIGN(auto factory, LookupStoreFactory::Create(comparator, std::make_shared<CacheManager>(1024 * 1024, 0.0), options));
44+
ASSERT_OK_AND_ASSIGN(
45+
auto factory,
46+
LookupStoreFactory::Create(comparator, std::make_shared<CacheManager>(1024 * 1024, 0.0),
47+
options));
4548
int64_t row_count = 6;
4649
ASSERT_OK_AND_ASSIGN(auto bloom_filter,
4750
LookupStoreFactory::BfGenerator(row_count, options, pool.get()));

src/paimon/common/sst/sst_file_io_test.cpp

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -75,8 +75,7 @@ class SstFileIOTest : public ::testing::TestWithParam<SstFileParam> {
7575
std::shared_ptr<paimon::MemoryPool> pool_;
7676

7777
MemorySlice::SliceComparator comparator_;
78-
std::shared_ptr<CacheManager> cache_manager_ =
79-
std::make_shared<CacheManager>(1024 * 1024, 0.0);
78+
std::shared_ptr<CacheManager> cache_manager_ = std::make_shared<CacheManager>(1024 * 1024, 0.0);
8079
};
8180

8281
TEST_P(SstFileIOTest, TestSimple) {
@@ -142,7 +141,8 @@ TEST_P(SstFileIOTest, TestSimple) {
142141

143142
// test read
144143
ASSERT_OK_AND_ASSIGN(in, fs_->Open(index_path));
145-
ASSERT_OK_AND_ASSIGN(auto reader, SstFileReader::Create(pool_, in, comparator_, cache_manager_));
144+
ASSERT_OK_AND_ASSIGN(auto reader,
145+
SstFileReader::Create(pool_, in, comparator_, cache_manager_));
146146

147147
// not exist key
148148
std::string k0 = "k0";
@@ -175,7 +175,8 @@ TEST_P(SstFileIOTest, TestJavaCompatibility) {
175175
ASSERT_OK_AND_ASSIGN(std::shared_ptr<InputStream> in, fs_->Open(file));
176176

177177
// test read
178-
ASSERT_OK_AND_ASSIGN(auto reader, SstFileReader::Create(pool_, in, comparator_, cache_manager_));
178+
ASSERT_OK_AND_ASSIGN(auto reader,
179+
SstFileReader::Create(pool_, in, comparator_, cache_manager_));
179180
// not exist key
180181
std::string k0 = "10000";
181182
ASSERT_FALSE(reader->Lookup(std::make_shared<Bytes>(k0, pool_.get())).value());

src/paimon/core/core_options.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ class PAIMON_EXPORT CoreOptions {
159159

160160
int64_t GetLookupCacheMaxMemory() const;
161161
double GetLookupCacheHighPrioPoolRatio() const;
162-
162+
163163
const std::map<std::string, std::string>& ToMap() const;
164164

165165
private:

src/paimon/core/mergetree/compact/lookup_merge_tree_compact_rewriter_test.cpp

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -316,8 +316,10 @@ class LookupMergeTreeCompactRewriterTest : public testing::Test {
316316
auto serializer_factory = std::make_shared<DefaultLookupSerializerFactory>();
317317
PAIMON_ASSIGN_OR_RAISE(auto lookup_key_comparator,
318318
RowCompactedSerializer::CreateSliceComparator(key_schema_, pool_));
319-
PAIMON_ASSIGN_OR_RAISE(auto lookup_store_factory,
320-
LookupStoreFactory::Create(lookup_key_comparator, std::make_shared<CacheManager>(1024 * 1024, 0.0), options));
319+
PAIMON_ASSIGN_OR_RAISE(
320+
auto lookup_store_factory,
321+
LookupStoreFactory::Create(lookup_key_comparator,
322+
std::make_shared<CacheManager>(1024 * 1024, 0.0), options));
321323
PAIMON_ASSIGN_OR_RAISE(auto path_factory, CreateFileStorePathFactory(table_path, options));
322324
return LookupLevels<T>::Create(
323325
fs_, BinaryRow::EmptyRow(), /*bucket=*/0, options, schema_manager,

src/paimon/core/mergetree/lookup_levels_test.cpp

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,8 +147,10 @@ class LookupLevelsTest : public testing::Test {
147147
auto serializer_factory = std::make_shared<DefaultLookupSerializerFactory>();
148148
PAIMON_ASSIGN_OR_RAISE(auto key_comparator,
149149
RowCompactedSerializer::CreateSliceComparator(key_schema_, pool_));
150-
PAIMON_ASSIGN_OR_RAISE(auto lookup_store_factory,
151-
LookupStoreFactory::Create(key_comparator, std::make_shared<CacheManager>(1024 * 1024, 0.0), options));
150+
PAIMON_ASSIGN_OR_RAISE(
151+
auto lookup_store_factory,
152+
LookupStoreFactory::Create(key_comparator,
153+
std::make_shared<CacheManager>(1024 * 1024, 0.0), options));
152154
PAIMON_ASSIGN_OR_RAISE(auto path_factory, CreateFileStorePathFactory(table_path, options));
153155
return LookupLevels<PositionedKeyValue>::Create(
154156
fs_, BinaryRow::EmptyRow(), /*bucket=*/0, options, schema_manager,

src/paimon/core/operation/key_value_file_store_write.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -74,8 +74,8 @@ KeyValueFileStoreWrite::KeyValueFileStoreWrite(
7474
merge_function_wrapper_(merge_function_wrapper),
7575
compact_manager_factory_(std::make_unique<MergeTreeCompactManagerFactory>(
7676
options_, key_comparator_, user_defined_seq_comparator_, compaction_metrics_,
77-
table_schema_, schema_, schema_manager_, io_manager_, cache_manager_, file_store_path_factory_,
78-
root_path_, pool_)),
77+
table_schema_, schema_, schema_manager_, io_manager_, cache_manager_,
78+
file_store_path_factory_, root_path_, pool_)),
7979
logger_(Logger::GetLogger("KeyValueFileStoreWrite")) {}
8080

8181
Result<std::unique_ptr<FileStoreScan>> KeyValueFileStoreWrite::CreateFileStoreScan(

0 commit comments

Comments
 (0)