Package | Description |
---|---|
org.apache.cassandra.db.streaming |
File transfer
|
Modifier and Type | Field and Description |
---|---|
static IVersionedSerializer<CassandraStreamHeader> |
CassandraStreamHeader.serializer |
Modifier and Type | Method and Description |
---|---|
CassandraStreamHeader |
CassandraStreamHeader.Builder.build() |
CassandraStreamHeader |
CassandraStreamHeader.CassandraStreamHeaderSerializer.deserialize(DataInputPlus in,
int version) |
CassandraStreamHeader |
CassandraStreamHeader.CassandraStreamHeaderSerializer.deserialize(DataInputPlus in,
int version,
java.util.function.Function<TableId,IPartitioner> partitionerMapper) |
Modifier and Type | Method and Description |
---|---|
void |
CassandraStreamHeader.CassandraStreamHeaderSerializer.serialize(CassandraStreamHeader header,
DataOutputPlus out,
int version) |
long |
CassandraStreamHeader.CassandraStreamHeaderSerializer.serializedSize(CassandraStreamHeader header,
int version) |
Constructor and Description |
---|
CassandraCompressedStreamReader(StreamMessageHeader header,
CassandraStreamHeader streamHeader,
StreamSession session) |
CassandraCompressedStreamWriter(SSTableReader sstable,
CassandraStreamHeader header,
StreamSession session) |
CassandraEntireSSTableStreamReader(StreamMessageHeader messageHeader,
CassandraStreamHeader streamHeader,
StreamSession session) |
CassandraStreamReader(StreamMessageHeader header,
CassandraStreamHeader streamHeader,
StreamSession session) |
CassandraStreamWriter(SSTableReader sstable,
CassandraStreamHeader header,
StreamSession session) |
Copyright © 2009-2022 The Apache Software Foundation