alluxio.client.block.stream

Class BlockOutStream

java.lang.Object

java.io.OutputStream

alluxio.client.block.stream.BlockOutStream

All Implemented Interfaces:

BoundedStream, Cancelable, Closeable, Flushable, AutoCloseable

Direct Known Subclasses:

UnderFileSystemFileOutStream

@NotThreadSafe
public class BlockOutStream
extends OutputStream
implements BoundedStream, Cancelable

Provides an OutputStream implementation that is based on PacketWriter which streams data packet by packet.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BlockOutStream(PacketWriter packetWriter, long length, WorkerNetAddress address) Constructs a new BlockOutStream with only one PacketWriter.

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancels an operation.
void	close()
static BlockOutStream	create(FileSystemContext context, long blockId, long blockSize, WorkerNetAddress address, OutStreamOptions options) Creates an BlockOutStream.
void	flush()
WorkerNetAddress	getAddress()
long	remaining()
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockOutStream

protected BlockOutStream(PacketWriter packetWriter,
                         long length,
                         WorkerNetAddress address)

Constructs a new BlockOutStream with only one PacketWriter.

Parameters:

packetWriter - the packet writer

length - the length of the stream

address - the Alluxio worker address

Method Detail

create

public static BlockOutStream create(FileSystemContext context,
                                    long blockId,
                                    long blockSize,
                                    WorkerNetAddress address,
                                    OutStreamOptions options)
                             throws IOException

Creates an BlockOutStream.

Parameters:

context - the file system context

blockId - the block ID

blockSize - the block size in bytes

address - the Alluxio worker address

options - the out stream options

Returns:

the OutputStream object

Throws:

IOException

remaining

public long remaining()

Specified by:

remaining in interface BoundedStream

Returns:

the remaining size of the block

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

write

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

Overrides:

write in class OutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

Throws:

IOException

cancel

public void cancel()
            throws IOException

Description copied from interface: Cancelable

Cancels an operation.

Specified by:

cancel in interface Cancelable

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class OutputStream

Throws:

IOException

getAddress

public WorkerNetAddress getAddress()

Returns:

the worker address for this stream