Methods in org.apache.cassandra.streaming with parameters of type IStreamCallback |
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,
long 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. |