Skip to content

Commit 9e227d2

Browse files
committed
Fix CI failure
Signed-off-by: dttung2905 <ttdao.2015@accountancy.smu.edu.sg>
1 parent 9962821 commit 9e227d2

File tree

3 files changed

+25
-25
lines changed

3 files changed

+25
-25
lines changed

manifest_test.go

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -784,28 +784,28 @@ func (m *ManifestTestSuite) TestV3DataManifestFirstRowIDInheritance() {
784784
EntryStatus: EntryStatusADDED,
785785
Snapshot: &entrySnapshotID,
786786
Data: &dataFile{
787-
Content: EntryContentData,
788-
Path: "/data/file1.parquet",
789-
Format: ParquetFile,
790-
PartitionData: map[string]any{"x": int(1)},
791-
RecordCount: firstCount,
792-
FileSize: 1000,
793-
BlockSizeInBytes: 64 * 1024,
794-
FirstRowIDField: nil, // null so reader will inherit
787+
Content: EntryContentData,
788+
Path: "/data/file1.parquet",
789+
Format: ParquetFile,
790+
PartitionData: map[string]any{"x": int(1)},
791+
RecordCount: firstCount,
792+
FileSize: 1000,
793+
BlockSizeInBytes: 64 * 1024,
794+
FirstRowIDField: nil, // null so reader will inherit
795795
},
796796
},
797797
&manifestEntry{
798798
EntryStatus: EntryStatusADDED,
799799
Snapshot: &entrySnapshotID,
800800
Data: &dataFile{
801-
Content: EntryContentData,
802-
Path: "/data/file2.parquet",
803-
Format: ParquetFile,
804-
PartitionData: map[string]any{"x": int(2)},
805-
RecordCount: secondCount,
806-
FileSize: 2000,
807-
BlockSizeInBytes: 64 * 1024,
808-
FirstRowIDField: nil,
801+
Content: EntryContentData,
802+
Path: "/data/file2.parquet",
803+
Format: ParquetFile,
804+
PartitionData: map[string]any{"x": int(2)},
805+
RecordCount: secondCount,
806+
FileSize: 2000,
807+
BlockSizeInBytes: 64 * 1024,
808+
FirstRowIDField: nil,
809809
},
810810
},
811811
}

metadata_columns.go

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -29,18 +29,18 @@ const (
2929

3030
// Row lineage metadata column names (v3+).
3131
const (
32-
RowIDColumnName = "_row_id"
33-
LastUpdatedSequenceNumberColumnName = "_last_updated_sequence_number"
32+
RowIDColumnName = "_row_id"
33+
LastUpdatedSequenceNumberColumnName = "_last_updated_sequence_number"
3434
)
3535

3636
// RowID returns a NestedField for _row_id (optional long) for use in schemas that include row lineage.
3737
func RowID() NestedField {
3838
return NestedField{
39-
ID: RowIDFieldID,
40-
Name: RowIDColumnName,
41-
Required: false,
42-
Doc: "Implicit row ID that is automatically assigned",
43-
Type: Int64Type{},
39+
ID: RowIDFieldID,
40+
Name: RowIDColumnName,
41+
Required: false,
42+
Doc: "Implicit row ID that is automatically assigned",
43+
Type: Int64Type{},
4444
}
4545
}
4646

table/scanner.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -502,8 +502,8 @@ type FileScanTask struct {
502502
// Row lineage (v3): constants used when reading to synthesize _row_id and _last_updated_sequence_number.
503503
// FirstRowID is the effective first_row_id for this file (from manifest entry, after inheritance).
504504
// DataSequenceNumber is the data sequence number of the file's manifest entry.
505-
FirstRowID *int64
506-
DataSequenceNumber *int64
505+
FirstRowID *int64
506+
DataSequenceNumber *int64
507507
}
508508

509509
// ToArrowRecords returns the arrow schema of the expected records and an interator

0 commit comments

Comments
 (0)