Uses of Class
org.apache.cassandra.streaming.StreamManager.StreamRateLimiter
-
Packages that use StreamManager.StreamRateLimiter Package Description org.apache.cassandra.db.streaming File transferorg.apache.cassandra.net org.apache.cassandra.streaming -
-
Uses of StreamManager.StreamRateLimiter in org.apache.cassandra.db.streaming
Fields in org.apache.cassandra.db.streaming declared as StreamManager.StreamRateLimiter Modifier and Type Field Description protected StreamManager.StreamRateLimiter
CassandraStreamWriter. limiter
-
Uses of StreamManager.StreamRateLimiter in org.apache.cassandra.net
Methods in org.apache.cassandra.net with parameters of type StreamManager.StreamRateLimiter Modifier and Type Method 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. -
Uses of StreamManager.StreamRateLimiter in org.apache.cassandra.streaming
Methods in org.apache.cassandra.streaming that return StreamManager.StreamRateLimiter Modifier and Type Method Description static StreamManager.StreamRateLimiter
StreamManager. getRateLimiter(InetAddressAndPort peer)
Gets streaming rate limiter.
-