dexorder/ai
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

iceberg schema version bump

Browse Source
This commit is contained in:
Tim Olson
2026-04-09 17:14:39 -04:00
parent fd431516cc
commit 7d231169d9
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
flink/src/main/java/com/dexorder/flink/iceberg/SchemaInitializer.java
View File

@@ -81,7 +81,7 @@ public class SchemaInitializer {
// Bump this when the schema changes. Tables with a different (or missing) version
// will be dropped and recreated. Increment by 1 for each incompatible change.
// v1: open/high/low/close required; ingestor forward-fills interior gaps with previous close
private static final String OHLC_SCHEMA_VERSION = "1";
private static final String OHLC_SCHEMA_VERSION = "5";
private static final String SCHEMA_VERSION_PROP = "app.schema.version";
private void initializeOhlcTable() {
@@ -179,7 +179,7 @@ public class SchemaInitializer {
// v2: removed tick_denom/base_denom/quote_denom; added Nautilus instrument fields
// (price_precision, size_precision, tick_size, lot_size, min_notional,
// margin_init, margin_maint, maker_fee, taker_fee, contract_multiplier)
private static final String SYMBOL_METADATA_SCHEMA_VERSION = "2";
private static final String SYMBOL_METADATA_SCHEMA_VERSION = "5";
private void initializeSymbolMetadataTable() {
TableIdentifier tableId = TableIdentifier.of(namespace, "symbol_metadata");

8
flink/src/main/java/com/dexorder/flink/publisher/OHLCBatchDeserializer.java
View File

@@ -65,10 +65,10 @@ public class OHLCBatchDeserializer implements DeserializationSchema<OHLCBatchWra
rows.add(new OHLCBatchWrapper.OHLCRow(
row.getTimestamp(),
row.getTicker(),
row.hasOpen() ? row.getOpen() : null,
row.hasHigh() ? row.getHigh() : null,
row.hasLow() ? row.getLow() : null,
row.hasClose() ? row.getClose() : null,
row.getOpen(),
row.getHigh(),
row.getLow(),
row.getClose(),
row.hasVolume() ? row.getVolume() : null
));
}