apache / fluss

[kv] Add basic implementation of AUTO_INCREMENT column (#2161)

Junbo Wang

Junbo Wang committed on Jan 6, 2026, 06:50 AM

Showing 28 changed files +1125 additions -71 deletions

M fluss-client/src/test/java/org/apache/fluss/client/table/FlussTableITCase.java +176

M fluss-common/src/main/java/org/apache/fluss/config/ConfigOptions.java +9 -10

M fluss-common/src/main/java/org/apache/fluss/config/TableConfig.java +5

A fluss-common/src/main/java/org/apache/fluss/exception/SequenceOverflowException.java +30

M fluss-common/src/main/java/org/apache/fluss/metadata/ChangelogImage.java +6 -5

M fluss-common/src/main/java/org/apache/fluss/metadata/Schema.java +25 -3

M fluss-common/src/test/java/org/apache/fluss/metadata/TableSchemaTest.java +14

M fluss-common/src/test/java/org/apache/fluss/utils/json/SchemaJsonSerdeTest.java +1 -1

M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/FlinkConnectorOptions.java +17 -1

M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkTableFactory.java +1

M fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/FlinkConversions.java +9 -8

M fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogITCase.java +7

M fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/sink/FlinkTableSinkITCase.java +58

M fluss-server/src/main/java/org/apache/fluss/server/SequenceIDCounter.java +8

M fluss-server/src/main/java/org/apache/fluss/server/coordinator/SchemaUpdate.java +5

M fluss-server/src/main/java/org/apache/fluss/server/kv/KvManager.java +11 -2

M fluss-server/src/main/java/org/apache/fluss/server/kv/KvTablet.java +35 -12

A fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/AutoIncrementManager.java +128

A fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/AutoIncrementUpdater.java +46

A fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/BoundedSegmentSequenceGenerator.java +119

A fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/PerSchemaAutoIncrementUpdater.java +112

A fluss-server/src/main/java/org/apache/fluss/server/kv/autoinc/SequenceGenerator.java +32

M fluss-server/src/main/java/org/apache/fluss/server/zk/ZkSequenceIDCounter.java +24 -1

M fluss-server/src/main/java/org/apache/fluss/server/zk/data/ZkData.java +22

M fluss-server/src/test/java/org/apache/fluss/server/kv/KvTabletTest.java +10 -1

A fluss-server/src/test/java/org/apache/fluss/server/kv/autoinc/SegmentSequenceGeneratorTest.java +182

M fluss-server/src/test/java/org/apache/fluss/server/kv/snapshot/KvTabletSnapshotTargetTest.java +5

M website/docs/engine-flink/options.md +28 -27

Browse files at this commit →