net.sansa_stack.hadoop.util

Class InterruptingReadableByteChannel

java.lang.Object

net.sansa_stack.hadoop.util.InterruptingReadableByteChannel

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, ReadableByteChannel, SeekableDecorator, org.apache.hadoop.fs.Seekable

public class InterruptingReadableByteChannel
extends Object
implements ReadableByteChannel, SeekableDecorator

ReadabalByteChannel whose read method is guaranteed to return at a specific position (before crossing it) such as a split boundary

Field Summary

Fields

Modifier and Type	Field and Description
protected byte[]	buffer
protected long	bytesRead
protected InputStream	in
protected boolean	interrupted
protected long	interruptPos
protected Consumer<InterruptingReadableByteChannel>	interruptPosFoundCallback
protected org.apache.hadoop.fs.Seekable	seekable

Constructor Summary

Constructors

Constructor and Description
InterruptingReadableByteChannel(InputStream in, org.apache.hadoop.fs.Seekable seekable, long interruptPos)
InterruptingReadableByteChannel(InputStream in, org.apache.hadoop.fs.Seekable seekable, long interruptPos, Consumer<InterruptingReadableByteChannel> interruptPosFoundCallback)

Method Summary

Modifier and Type	Method and Description
void	close()
long	getBytesRead()
org.apache.hadoop.fs.Seekable	getSeekable()
boolean	isOpen()
int	read(ByteBuffer byteBuffer)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.sansa_stack.hadoop.util.SeekableDecorator

getPos, seek, seekToNewSource

Field Detail

buffer

protected byte[] buffer

interrupted

protected boolean interrupted

in

protected InputStream in

seekable

protected org.apache.hadoop.fs.Seekable seekable

interruptPos

protected long interruptPos

bytesRead

protected long bytesRead

interruptPosFoundCallback

protected Consumer<InterruptingReadableByteChannel> interruptPosFoundCallback

Constructor Detail

InterruptingReadableByteChannel

public InterruptingReadableByteChannel(InputStream in,
                                       org.apache.hadoop.fs.Seekable seekable,
                                       long interruptPos)

InterruptingReadableByteChannel

public InterruptingReadableByteChannel(InputStream in,
                                       org.apache.hadoop.fs.Seekable seekable,
                                       long interruptPos,
                                       Consumer<InterruptingReadableByteChannel> interruptPosFoundCallback)

Method Detail

read

public int read(ByteBuffer byteBuffer)
         throws IOException

Specified by:

read in interface ReadableByteChannel

Throws:

IOException

getBytesRead

public long getBytesRead()

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Throws:

IOException

getSeekable

public org.apache.hadoop.fs.Seekable getSeekable()

Specified by:

getSeekable in interface SeekableDecorator