Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/239#discussion_r200708031
--- Diff:
src/java/org/apache/cassandra/db/streaming/CassandraOutgoingFile.java ---
@@ -62,7 +88,20 @@ public CassandraOutgoingFile(StreamOperation operation,
Ref<SSTableReader> ref,
sections,
sstable.compression ?
sstable.getCompressionMetadata() : null,
keepSSTableLevel ?
sstable.getSSTableLevel() : 0,
-
sstable.header.toComponent());
+
sstable.header.toComponent(), components, shouldStreamFullSSTable());
+ }
+
+ private static List<ComponentInfo> getComponents(SSTableReader sstable)
+ {
+ List<ComponentInfo> result = new
ArrayList<>(STREAM_COMPONENTS.size());
+ for (Component component : STREAM_COMPONENTS)
+ {
+ File file = new
File(sstable.descriptor.filenameFor(component));
+ if (file.exists())
+ result.add(new ComponentInfo(component.type,
file.length()));
--- End diff --
missing braces
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
