Package | Description |
---|---|
org.apache.cassandra.streaming |
Modifier and Type | Field and Description |
---|---|
protected IStreamCallback |
AbstractStreamSession.callback |
Modifier and Type | Method and Description |
---|---|
static StreamInSession |
StreamInSession.create(java.net.InetAddress host,
IStreamCallback callback) |
static StreamOutSession |
StreamOutSession.create(java.lang.String table,
java.net.InetAddress host,
IStreamCallback callback) |
static StreamOutSession |
StreamOutSession.create(java.lang.String table,
java.net.InetAddress host,
java.util.UUID sessionId,
IStreamCallback callback) |
static void |
StreamIn.requestRanges(java.net.InetAddress source,
java.lang.String tableName,
java.util.Collection<ColumnFamilyStore> columnFamilies,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Request ranges to be transferred from specific CFs
|
static void |
StreamIn.requestRanges(java.net.InetAddress source,
java.lang.String tableName,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Request ranges for all column families in the given keyspace.
|
static void |
StreamOut.transferRanges(java.net.InetAddress target,
Table table,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Stream the given ranges to the target endpoint from each CF in the given keyspace.
|
static void |
StreamOut.transferRanges(java.net.InetAddress target,
Table table,
java.lang.Iterable<ColumnFamilyStore> cfses,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Stream the given ranges to the target endpoint for provided CFs in the given keyspace.
|
Constructor and Description |
---|
AbstractStreamSession(java.lang.String table,
java.net.InetAddress host,
java.util.UUID sessionId,
IStreamCallback callback) |
Copyright © 2014 The Apache Software Foundation