org.apache.ignite.internal.processors.hadoop.shuffle.direct

Class HadoopDirectDataOutput

java.lang.Object

java.io.OutputStream

org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput

All Implemented Interfaces:

Closeable, DataOutput, Flushable, AutoCloseable

public class HadoopDirectDataOutput
extends OutputStream
implements DataOutput

Hadoop data output for direct communication.

Constructor Summary

Constructors

Constructor and Description
HadoopDirectDataOutput(int flushSize) Constructor.
HadoopDirectDataOutput(int flushSize, int allocSize) Constructor.

Method Summary

Modifier and Type	Method and Description
byte[]	buffer()
int	bufferLength()
int	position()
boolean	readyForFlush()
void	reset() Reset the stream.
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int val)
void	writeBoolean(boolean val)
void	writeByte(int val)
void	writeBytes(String str)
void	writeChar(int val)
void	writeChars(String str)
void	writeDouble(double val)
void	writeFloat(float val)
void	writeInt(int val)
void	writeLong(long val)
void	writeShort(int val)
void	writeUTF(String str)

Methods inherited from class java.io.OutputStream

close, flush

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopDirectDataOutput

public HadoopDirectDataOutput(int flushSize)

Constructor.

Parameters:

flushSize - Flush size.

HadoopDirectDataOutput

public HadoopDirectDataOutput(int flushSize,
                              int allocSize)

Constructor.

Parameters:

flushSize - Flush size.

allocSize - Allocation size.

Method Detail

write

public void write(@NotNull
                  byte[] b)
           throws IOException

Specified by:

write in interface DataOutput

Overrides:

write in class OutputStream

Throws:

IOException

write

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

Specified by:

write in interface DataOutput

Overrides:

write in class OutputStream

Throws:

IOException

write

public void write(int val)
           throws IOException

Specified by:

write in interface DataOutput

Specified by:

write in class OutputStream

Throws:

IOException

writeBoolean

public void writeBoolean(boolean val)
                  throws IOException

Specified by:

writeBoolean in interface DataOutput

Throws:

IOException

writeByte

public void writeByte(int val)
               throws IOException

Specified by:

writeByte in interface DataOutput

Throws:

IOException

writeShort

public void writeShort(int val)
                throws IOException

Specified by:

writeShort in interface DataOutput

Throws:

IOException

writeChar

public void writeChar(int val)
               throws IOException

Specified by:

writeChar in interface DataOutput

Throws:

IOException

writeInt

public void writeInt(int val)
              throws IOException

Specified by:

writeInt in interface DataOutput

Throws:

IOException

writeLong

public void writeLong(long val)
               throws IOException

Specified by:

writeLong in interface DataOutput

Throws:

IOException

writeFloat

public void writeFloat(float val)
                throws IOException

Specified by:

writeFloat in interface DataOutput

Throws:

IOException

writeDouble

public void writeDouble(double val)
                 throws IOException

Specified by:

writeDouble in interface DataOutput

Throws:

IOException

writeBytes

public void writeBytes(@NotNull
                       String str)
                throws IOException

Specified by:

writeBytes in interface DataOutput

Throws:

IOException

writeChars

public void writeChars(@NotNull
                       String str)
                throws IOException

Specified by:

writeChars in interface DataOutput

Throws:

IOException

writeUTF

public void writeUTF(@NotNull
                     String str)
              throws IOException

Specified by:

writeUTF in interface DataOutput

Throws:

IOException

buffer

public byte[] buffer()

Returns:

Buffer.

bufferLength

public int bufferLength()

Returns:

Buffer length (how much memory is allocated).

position

public int position()

Returns:

Position.

readyForFlush

public boolean readyForFlush()

Returns:

Whether buffer is ready for flush.

reset

public void reset()

Reset the stream.