Package | Description |
---|---|
org.apache.cassandra.db.streaming |
File transfer
|
org.apache.cassandra.net | |
org.apache.cassandra.streaming |
Modifier and Type | Field and Description |
---|---|
protected StreamManager.StreamRateLimiter |
CassandraStreamWriter.limiter |
Modifier and Type | Method and Description |
---|---|
long |
AsyncStreamingOutputPlus.writeFileToChannel(java.nio.channels.FileChannel file,
StreamManager.StreamRateLimiter limiter)
Writes all data in file channel to stream:
* For zero-copy-streaming, 1MiB at a time, with at most 2MiB in flight at once. |
int |
AsyncStreamingOutputPlus.writeToChannel(AsyncStreamingOutputPlus.Write write,
StreamManager.StreamRateLimiter limiter)
Provide a lambda that can request a buffer of suitable size, then fill the buffer and have
that buffer written and flushed to the underlying channel, without having to handle buffer
allocation, lifetime or cleanup, including in case of exceptions.
|
Modifier and Type | Method and Description |
---|---|
static StreamManager.StreamRateLimiter |
StreamManager.getRateLimiter(InetAddressAndPort peer)
Gets streaming rate limiter.
|
Copyright © 2009-2022 The Apache Software Foundation