diff --git a/src/backend/columnar/cstore_metadata_tables.c b/src/backend/columnar/cstore_metadata_tables.c index b51e1dde4..ef72acc72 100644 --- a/src/backend/columnar/cstore_metadata_tables.c +++ b/src/backend/columnar/cstore_metadata_tables.c @@ -153,16 +153,16 @@ typedef FormData_columnar_options *Form_columnar_options; #define Anum_columnar_chunk_stripe 2 #define Anum_columnar_chunk_attr 3 #define Anum_columnar_chunk_chunk 4 -#define Anum_columnar_chunk_value_count 5 -#define Anum_columnar_chunk_minimum_value 6 -#define Anum_columnar_chunk_maximum_value 7 -#define Anum_columnar_chunk_value_stream_offset 8 -#define Anum_columnar_chunk_value_stream_length 9 -#define Anum_columnar_chunk_exists_stream_offset 10 -#define Anum_columnar_chunk_exists_stream_length 11 -#define Anum_columnar_chunk_value_compression_type 12 -#define Anum_columnar_chunk_value_compression_level 13 -#define Anum_columnar_chunk_value_decompressed_size 14 +#define Anum_columnar_chunk_minimum_value 5 +#define Anum_columnar_chunk_maximum_value 6 +#define Anum_columnar_chunk_value_stream_offset 7 +#define Anum_columnar_chunk_value_stream_length 8 +#define Anum_columnar_chunk_exists_stream_offset 9 +#define Anum_columnar_chunk_exists_stream_length 10 +#define Anum_columnar_chunk_value_compression_type 11 +#define Anum_columnar_chunk_value_compression_level 12 +#define Anum_columnar_chunk_value_decompressed_size 13 +#define Anum_columnar_chunk_value_count 14 /* @@ -430,7 +430,6 @@ SaveStripeSkipList(RelFileNode relfilenode, uint64 stripe, StripeSkipList *chunk Int64GetDatum(stripe), Int32GetDatum(columnIndex + 1), Int32GetDatum(chunkIndex), - Int64GetDatum(chunk->rowCount), 0, /* to be filled below */ 0, /* to be filled below */ Int64GetDatum(chunk->valueChunkOffset), @@ -439,7 +438,8 @@ SaveStripeSkipList(RelFileNode relfilenode, uint64 stripe, StripeSkipList *chunk Int64GetDatum(chunk->existsLength), Int32GetDatum(chunk->valueCompressionType), Int32GetDatum(chunk->valueCompressionLevel), - Int64GetDatum(chunk->decompressedValueSize) + Int64GetDatum(chunk->decompressedValueSize), + Int64GetDatum(chunk->rowCount) }; bool nulls[Natts_columnar_chunk] = { false }; diff --git a/src/backend/columnar/sql/columnar--9.5-1--10.0-1.sql b/src/backend/columnar/sql/columnar--9.5-1--10.0-1.sql index 065c29eba..5b6b9b775 100644 --- a/src/backend/columnar/sql/columnar--9.5-1--10.0-1.sql +++ b/src/backend/columnar/sql/columnar--9.5-1--10.0-1.sql @@ -45,7 +45,6 @@ CREATE TABLE chunk ( stripeid bigint NOT NULL, attnum int NOT NULL, chunkid int NOT NULL, - value_count bigint NOT NULL, minimum_value bytea, maximum_value bytea, value_stream_offset bigint NOT NULL, @@ -55,6 +54,7 @@ CREATE TABLE chunk ( value_compression_type int NOT NULL, value_compression_level int NOT NULL, value_decompressed_length bigint NOT NULL, + value_count bigint NOT NULL, PRIMARY KEY (storageid, stripeid, attnum, chunkid), FOREIGN KEY (storageid, stripeid, chunkid) REFERENCES chunk_group(storageid, stripeid, chunkid) ON DELETE CASCADE ) WITH (user_catalog_table = true);