Skip to content

Commit 5110375

Browse files
Address Minor PR Comments
1 parent c32b81a commit 5110375

File tree

4 files changed

+8
-8
lines changed

4 files changed

+8
-8
lines changed

persistence/nosql/idgen/api/src/main/java/org/apache/polaris/ids/api/IdGenerator.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,12 @@
1818
*/
1919
package org.apache.polaris.ids.api;
2020

21+
/** The primary interface for generating a contention-free ID. */
2122
public interface IdGenerator {
2223
/** Generate a new, unique ID. */
2324
long generateId();
2425

25-
/** Generate the system ID for a node, solely used by/for node management purposes. */
26+
/** Generate the system ID for a node, solely used for node management. */
2627
long systemIdForNode(int nodeId);
2728

2829
default String describeId(long id) {
@@ -33,12 +34,12 @@ default String describeId(long id) {
3334
new IdGenerator() {
3435
@Override
3536
public long generateId() {
36-
throw new UnsupportedOperationException("NONE IdGenerator");
37+
throw new UnsupportedOperationException("NONE IdGenerator cannot generate IDs.");
3738
}
3839

3940
@Override
4041
public long systemIdForNode(int nodeId) {
41-
throw new UnsupportedOperationException("NONE IdGenerator");
42+
throw new UnsupportedOperationException("NONE IdGenerator cannot generate IDs.");
4243
}
4344
};
4445
}

persistence/nosql/idgen/api/src/main/java/org/apache/polaris/ids/api/SnowflakeIdGenerator.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,7 @@
2525

2626
public interface SnowflakeIdGenerator extends IdGenerator {
2727
/** Offset of the snowflake ID generator since the 1970-01-01T00:00:00Z epoch instant. */
28-
Instant EPOCH_OFFSET =
29-
Instant.EPOCH.atZone(ZoneId.of("GMT")).withYear(2025).withMonth(3).toInstant();
28+
Instant EPOCH_OFFSET = Instant.parse("2025-03-01T00:00:00Z");
3029

3130
/**
3231
* Offset of the snowflake ID generator in milliseconds since the 1970-01-01T00:00:00Z epoch

persistence/nosql/idgen/impl/src/main/java/org/apache/polaris/ids/impl/SnowflakeIdGeneratorFactory.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,8 +50,7 @@ public void validateParameters(Map<String, String> params, IdGeneratorSource idG
5050
}
5151

5252
@Override
53-
public SnowflakeIdGenerator buildSystemIdGenerator(
54-
Map<String, String> params, LongSupplier clockMillis) {
53+
public SnowflakeIdGenerator buildSystemIdGenerator(Map<String, String> params) {
5554
return buildIdGenerator(
5655
params,
5756
new IdGeneratorSource() {

persistence/nosql/idgen/spi/src/main/java/org/apache/polaris/ids/spi/IdGeneratorFactory.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,14 +23,15 @@
2323
import java.util.function.LongSupplier;
2424
import org.apache.polaris.ids.api.IdGenerator;
2525

26+
/** Provides values for ID generators, usually provided by {@code NodeLease} implementations. */
2627
public interface IdGeneratorFactory<I extends IdGenerator> {
2728
String name();
2829

2930
void validateParameters(Map<String, String> params, IdGeneratorSource idGeneratorSource);
3031

3132
I buildIdGenerator(Map<String, String> params, IdGeneratorSource idGeneratorSource);
3233

33-
I buildSystemIdGenerator(Map<String, String> params, LongSupplier clockMillis);
34+
I buildSystemIdGenerator(Map<String, String> params);
3435

3536
static IdGeneratorFactory<?> lookupFactory(String name) {
3637
for (IdGeneratorFactory<?> factory : ServiceLoader.load(IdGeneratorFactory.class)) {

0 commit comments

Comments
 (0)