gobblin.util.io

Class MeteredInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

gobblin.util.io.MeteredInputStream

All Implemented Interfaces:

MeteredStream, Closeable, AutoCloseable

public class MeteredInputStream
extends FilterInputStream
implements MeteredStream

A FilterInputStream that counts the bytes read from the underlying InputStream.

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Method Summary

Modifier and Type	Method and Description
static Optional<MeteredInputStream>	findWrappedMeteredInputStream(InputStream is) Find the lowest MeteredInputStream in a chain of FilterInputStreams.
com.codahale.metrics.Meter	getBytesProcessedMeter()
int	read()
int	read(byte[] b, int off, int len)

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, reset, skip

Methods inherited from class java.lang.Object

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

Method Detail

findWrappedMeteredInputStream

public static Optional<MeteredInputStream> findWrappedMeteredInputStream(InputStream is)

Find the lowest MeteredInputStream in a chain of FilterInputStreams.

read

public int read()
         throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

read

public int read(byte[] b,
                int off,
                int len)
         throws IOException

Overrides:

read in class FilterInputStream

Throws:

IOException

getBytesProcessedMeter

public com.codahale.metrics.Meter getBytesProcessedMeter()

Specified by:

getBytesProcessedMeter in interface MeteredStream

Returns:

The Meter measuring the bytes processed.