We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 00b96cd commit 3e539beCopy full SHA for 3e539be
src/iceberg/json_internal.cc
@@ -401,7 +401,7 @@ Result<std::unique_ptr<PartitionField>> PartitionFieldFromJson(
401
ICEBERG_ASSIGN_OR_RAISE(auto field_id, GetJsonValue<int32_t>(json, kFieldId));
402
ICEBERG_ASSIGN_OR_RAISE(
403
auto transform,
404
- GetJsonValue<std::string>(json, kTransform).and_then(TransformFunctionFromString));
+ GetJsonValue<std::string>(json, kTransform).and_then(TransformFromString));
405
ICEBERG_ASSIGN_OR_RAISE(auto name, GetJsonValue<std::string>(json, kName));
406
return std::make_unique<PartitionField>(source_id, field_id, name,
407
std::move(transform));
test/json_internal_test.cc
@@ -102,7 +102,7 @@ TEST(JsonInternalTest, SortOrder) {
102
}
103
104
TEST(JsonInternalTest, PartitionField) {
105
- auto identity_transform = std::make_shared<IdentityTransformFunction>();
+ auto identity_transform = Transform::Identity();
106
PartitionField field(3, 101, "region", identity_transform);
107
nlohmann::json expected_json =
108
R"({"source-id":3,"field-id":101,"transform":"identity","name":"region"})"_json;
@@ -125,7 +125,7 @@ TEST(JsonPartitionTest, PartitionSpec) {
125
SchemaField(3, "region", std::make_shared<StringType>(), false),
126
SchemaField(5, "ts", std::make_shared<LongType>(), false)});
127
128
129
PartitionSpec spec(schema, 1,
130
{PartitionField(3, 101, "region", identity_transform),
131
PartitionField(5, 102, "ts", identity_transform)});
0 commit comments