Github user dineshjoshi commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/239#discussion_r205526764
--- Diff:
src/java/org/apache/cassandra/db/streaming/CassandraStreamHeader.java ---
@@ -65,18 +85,43 @@ private CassandraStreamHeader(Version version,
SSTableFormat.Type format, long e
this.compressionInfo = compressionInfo;
this.sstableLevel = sstableLevel;
this.header = header;
-
+ this.fullStream = fullStream;
+ this.componentManifest = componentManifest;
+ this.firstKey = firstKey;
+ this.tableId = tableId;
this.size = calculateSize();
}
- public CassandraStreamHeader(Version version, SSTableFormat.Type
format, long estimatedKeys, List<SSTableReader.PartitionPositionBounds>
sections, CompressionMetadata compressionMetadata, int sstableLevel,
SerializationHeader.Component header)
+ private CassandraStreamHeader(Version version, SSTableFormat.Type
format, long estimatedKeys,
--- End diff --
I have cherry picked this change. Thanks!
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
