alluxio.client.block.stream

Interface PacketWriter

All Superinterfaces:

AutoCloseable, Cancelable, Closeable

All Known Implementing Classes:

LocalFilePacketWriter, NettyPacketWriter

public interface PacketWriter
extends Closeable, Cancelable

The interface to write packets.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	PacketWriter.Factory Factory for PacketWriter.

Method Summary

Modifier and Type	Method and Description
void	flush() Flushes all the pending packets.
int	packetSize()
long	pos()
void	writePacket(io.netty.buffer.ByteBuf packet) Writes a packet.

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface alluxio.client.Cancelable

cancel

Method Detail

writePacket

void writePacket(io.netty.buffer.ByteBuf packet)
          throws IOException

Writes a packet. This method takes the ownership of this packet even if it fails to write the packet.

Parameters:

packet - the packet

Throws:

IOException

flush

void flush()
    throws IOException

Flushes all the pending packets.

Throws:

IOException

packetSize

int packetSize()

Returns:

the packet size in bytes used

pos

long pos()

Returns:

the current pos which is the same as the totally number of bytes written so far