Package | Description |
---|---|
org.apache.cassandra.io.sstable | |
org.apache.cassandra.streaming |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.net.InetAddress,java.util.Collection<PendingFile>> |
SSTableLoader.LoaderFuture.getPendingFiles() |
Modifier and Type | Field and Description |
---|---|
PendingFile |
StreamHeader.file
file being sent on initial stream
|
protected PendingFile |
StreamRequest.file |
protected PendingFile |
IncomingStreamReader.localFile |
protected PendingFile |
IncomingStreamReader.remoteFile |
Modifier and Type | Field and Description |
---|---|
java.util.Collection<PendingFile> |
StreamHeader.pendingFiles
files to add to the session
|
Modifier and Type | Method and Description |
---|---|
PendingFile |
PendingFile.PendingFileSerializer.deserialize(java.io.DataInput dis,
int version) |
static PendingFile |
StreamIn.getContextMapping(PendingFile remote)
Translates remote files to local files by creating a local sstable per remote sstable.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<PendingFile> |
StreamOutSession.getFiles() |
static java.util.Set<PendingFile> |
StreamInSession.getIncomingFiles(java.net.InetAddress host)
query the status of incoming files.
|
static java.util.List<PendingFile> |
StreamOutSession.getOutgoingFiles(java.net.InetAddress host) |
Modifier and Type | Method and Description |
---|---|
void |
StreamInSession.finished(PendingFile remoteFile,
SSTableWriter writer) |
static PendingFile |
StreamIn.getContextMapping(PendingFile remote)
Translates remote files to local files by creating a local sstable per remote sstable.
|
void |
StreamInSession.retry(PendingFile remoteFile) |
void |
PendingFile.PendingFileSerializer.serialize(PendingFile sc,
java.io.DataOutput dos,
int version) |
long |
PendingFile.PendingFileSerializer.serializedSize(PendingFile pf,
int version) |
void |
StreamInSession.setCurrentFile(PendingFile file) |
Modifier and Type | Method and Description |
---|---|
void |
StreamInSession.addFiles(java.util.Collection<PendingFile> files) |
void |
StreamOutSession.addFilesToStream(java.util.List<PendingFile> pendingFiles) |
Constructor and Description |
---|
PendingFile(Descriptor desc,
PendingFile pf) |
StreamHeader(java.lang.String table,
java.util.UUID sessionId,
PendingFile file) |
StreamHeader(java.lang.String table,
java.util.UUID sessionId,
PendingFile first,
java.util.Collection<PendingFile> pendingFiles) |
Constructor and Description |
---|
StreamHeader(java.lang.String table,
java.util.UUID sessionId,
PendingFile first,
java.util.Collection<PendingFile> pendingFiles) |
Copyright © 2014 The Apache Software Foundation