Package gobblin.util.io

Interface Summary

Interface	Description
MeteredStream	A InputStream or OutputStream that measures bytes processed.

Class Summary

Class	Description
AdditionalCloseableInputStream	An extension of FSDataInputStream that takes additional Closeable objects, which will all be closed when InputStream is closed.
BatchedMeterDecorator	A decorator to a Meter that batches updates for performance.
CloseableHttpConn	Wraps a HttpURLConnection into a Closeable object.
FilterStreamUnpacker	Contains utilities for getting uderlying streams to a filter stream.
GsonInterfaceAdapter	A Gson interface adapter that makes it possible to serialize and deserialize polymorphic objects.
MeteredInputStream	A FilterInputStream that counts the bytes read from the underlying InputStream.
MeteredOutputStream	A FilterOutputStream that counts the bytes read from the underlying OutputStream.
SeekableFSInputStream	Class that wraps an InputStream to support Seekable and PositionedReadable
StreamCopier	A class that copies an InputStream to an OutputStream in a configurable way.
StreamCopierSharedLimiterKey	A subclass of SharedLimiterKey with more detailed information on the source and target of a throttled StreamCopier.
StreamThrottler<S extends ScopeType<S>>	A class used to throttle InputStreams.
StreamThrottler.Factory<S extends ScopeType<S>>	A SharedResourceFactory that creates StreamThrottler.
StreamUtils	Utility class of input/output stream helpers.
ThrottledInputStream	A throttled InputStream.

Exception Summary

Exception	Description
StreamCopier.NotEnoughPermitsException	Indicates there were not enough permits in the Limiter to finish the copy.