org.apache.spark.streaming.util

Class RateLimitedOutputStream

Object

java.io.OutputStream

org.apache.spark.streaming.util.RateLimitedOutputStream

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, AutoCloseable, Logging

public class RateLimitedOutputStream
extends java.io.OutputStream
implements Logging

Constructor Summary

Constructors

Constructor and Description
RateLimitedOutputStream(java.io.OutputStream out, int desiredBytesPerSec)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	flush()
void	write(byte[] bytes)
void	write(byte[] bytes, int offset, int length)
void	write(int b)

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

RateLimitedOutputStream

public RateLimitedOutputStream(java.io.OutputStream out,
                       int desiredBytesPerSec)

Method Detail

write

public void write(int b)

Specified by:

write in class java.io.OutputStream

write

public void write(byte[] bytes)

Overrides:

write in class java.io.OutputStream

write

public final void write(byte[] bytes,
         int offset,
         int length)

Overrides:

write in class java.io.OutputStream

flush

public void flush()

Specified by:

flush in interface java.io.Flushable

Overrides:

flush in class java.io.OutputStream

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class java.io.OutputStream