Skip to content

Commit 1a3f827

Browse files
committed
Fix review comments
1 parent a00cc3c commit 1a3f827

File tree

3 files changed

+15
-25
lines changed

3 files changed

+15
-25
lines changed

velox/connectors/hive/iceberg/IcebergDataSink.cpp

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,21 @@ folly::dynamic extractPartitionValue<TypeKind::TIMESTAMP>(
6565
return timestamp.toMicros();
6666
}
6767

68+
class IcebergInsertFileNameGenerator : public FileNameGenerator {
69+
public:
70+
IcebergInsertFileNameGenerator() {}
71+
72+
std::pair<std::string, std::string> gen(
73+
std::optional<uint32_t> bucketId,
74+
const std::shared_ptr<const HiveInsertTableHandle> insertTableHandle,
75+
const ConnectorQueryCtx& connectorQueryCtx,
76+
bool commitRequired) const override;
77+
78+
folly::dynamic serialize() const override;
79+
80+
std::string toString() const override;
81+
};
82+
6883
} // namespace
6984

7085
std::pair<std::string, std::string> IcebergInsertFileNameGenerator::gen(

velox/connectors/hive/iceberg/IcebergDataSink.h

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -22,21 +22,6 @@
2222

2323
namespace facebook::velox::connector::hive::iceberg {
2424

25-
class IcebergInsertFileNameGenerator : public FileNameGenerator {
26-
public:
27-
IcebergInsertFileNameGenerator() {}
28-
29-
std::pair<std::string, std::string> gen(
30-
std::optional<uint32_t> bucketId,
31-
const std::shared_ptr<const HiveInsertTableHandle> insertTableHandle,
32-
const ConnectorQueryCtx& connectorQueryCtx,
33-
bool commitRequired) const override;
34-
35-
folly::dynamic serialize() const override;
36-
37-
std::string toString() const override;
38-
};
39-
4025
// Represents a request for Iceberg write.
4126
class IcebergInsertTableHandle final : public HiveInsertTableHandle {
4227
public:

velox/connectors/hive/iceberg/IcebergPartitionIdGenerator.cpp

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -23,16 +23,6 @@ namespace facebook::velox::connector::hive::iceberg {
2323

2424
namespace {
2525

26-
std::string toLower(const std::string& data) {
27-
std::string ret;
28-
ret.reserve(data.size());
29-
std::transform(
30-
data.begin(), data.end(), std::back_inserter(ret), [](auto& c) {
31-
return std::tolower(c);
32-
});
33-
return ret;
34-
}
35-
3626
template <TypeKind Kind>
3727
std::pair<std::string, std::string> makePartitionKeyValueString(
3828
const BaseVector* partitionVector,

0 commit comments

Comments
 (0)