Package | Description |
---|---|
org.apache.cassandra.db.streaming |
File transfer
|
org.apache.cassandra.io.compress | |
org.apache.cassandra.io.sstable.format |
Modifier and Type | Field and Description |
---|---|
java.util.List<SSTableReader.PartitionPositionBounds> |
CassandraStreamHeader.sections |
protected java.util.Collection<SSTableReader.PartitionPositionBounds> |
CassandraStreamReader.sections |
protected java.util.Collection<SSTableReader.PartitionPositionBounds> |
CassandraStreamWriter.sections |
Modifier and Type | Method and Description |
---|---|
boolean |
CassandraOutgoingFile.contained(java.util.List<SSTableReader.PartitionPositionBounds> sections,
SSTableReader sstable) |
CassandraStreamHeader.Builder |
CassandraStreamHeader.Builder.withSections(java.util.List<SSTableReader.PartitionPositionBounds> sections) |
Constructor and Description |
---|
CassandraOutgoingFile(StreamOperation operation,
Ref<SSTableReader> ref,
java.util.List<SSTableReader.PartitionPositionBounds> sections,
java.util.List<Range<Token>> normalizedRanges,
long estimatedKeys) |
Modifier and Type | Method and Description |
---|---|
CompressionMetadata.Chunk[] |
CompressionMetadata.getChunksForSections(java.util.Collection<SSTableReader.PartitionPositionBounds> sections) |
long |
CompressionMetadata.getTotalSizeForSections(java.util.Collection<SSTableReader.PartitionPositionBounds> sections) |
Modifier and Type | Method and Description |
---|---|
java.util.List<SSTableReader.PartitionPositionBounds> |
SSTableReader.getPositionsForRanges(java.util.Collection<Range<Token>> ranges)
Determine the minimal set of sections that can be extracted from this SSTable to cover the given ranges.
|
Copyright © 2009-2022 The Apache Software Foundation