Uses of Interface
org.apache.cassandra.streaming.StreamingDataOutputPlus.RateLimiter

Packages that use StreamingDataOutputPlus.RateLimiter

Package	Description
org.apache.cassandra.net
org.apache.cassandra.streaming

Uses of StreamingDataOutputPlus.RateLimiter in org.apache.cassandra.net

Methods in org.apache.cassandra.net with parameters of type StreamingDataOutputPlus.RateLimiter

Modifier and Type	Method	Description
long	AsyncStreamingOutputPlus.writeFileToChannel(FileChannel file, StreamingDataOutputPlus.RateLimiter 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(StreamingDataOutputPlus.Write write, StreamingDataOutputPlus.RateLimiter 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 StreamingDataOutputPlus.RateLimiter in org.apache.cassandra.streaming

Classes in org.apache.cassandra.streaming that implement StreamingDataOutputPlus.RateLimiter

Modifier and Type	Class	Description
static class	StreamManager.StreamRateLimiter

Methods in org.apache.cassandra.streaming with parameters of type StreamingDataOutputPlus.RateLimiter

Modifier and Type	Method	Description
long	StreamingDataOutputPlus.writeFileToChannel(FileChannel file, StreamingDataOutputPlus.RateLimiter 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.
long	StreamingDataOutputPlusFixed.writeFileToChannel(FileChannel file, StreamingDataOutputPlus.RateLimiter limiter)
int	StreamingDataOutputPlus.writeToChannel(StreamingDataOutputPlus.Write write, StreamingDataOutputPlus.RateLimiter 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.
int	StreamingDataOutputPlusFixed.writeToChannel(StreamingDataOutputPlus.Write write, StreamingDataOutputPlus.RateLimiter limiter)