public class OutStream extends PositionedOutputStream
Modifier and Type | Field and Description |
---|---|
static int |
HEADER_SIZE |
Constructor and Description |
---|
OutStream(String name,
int bufferSize,
CompressionCodec codec,
PhysicalWriter.OutputReceiver receiver) |
Modifier and Type | Method and Description |
---|---|
static void |
assertBufferSizeValid(int bufferSize)
Throws exception if the bufferSize argument equals or exceeds 2^(3*8 - 1).
|
void |
clear() |
void |
flush() |
long |
getBufferSize()
Get the memory size currently allocated as buffer associated with this
stream.
|
void |
getPosition(PositionRecorder recorder)
Record the current position to the recorder.
|
void |
suppress()
Set suppress flag
|
String |
toString() |
void |
write(byte[] bytes,
int offset,
int length) |
void |
write(int i) |
close, write
public static final int HEADER_SIZE
public OutStream(String name, int bufferSize, CompressionCodec codec, PhysicalWriter.OutputReceiver receiver) throws IOException
IOException
public void clear() throws IOException
IOException
public static void assertBufferSizeValid(int bufferSize) throws IllegalArgumentException
writeHeader(ByteBuffer, int, int, boolean)
.
The bufferSize needs to be expressible in 3 bytes, and uses the least significant byte
to indicate original/compressed bytes.bufferSize
- The ORC compression buffer size being checked.IllegalArgumentException
- If bufferSize value exceeds threshold.public void write(int i) throws IOException
write
in class OutputStream
IOException
public void write(byte[] bytes, int offset, int length) throws IOException
write
in class OutputStream
IOException
public void getPosition(PositionRecorder recorder) throws IOException
PositionedOutputStream
getPosition
in class PositionedOutputStream
recorder
- the object that receives the positionIOException
public void flush() throws IOException
flush
in interface Flushable
flush
in class OutputStream
IOException
public long getBufferSize()
PositionedOutputStream
getBufferSize
in class PositionedOutputStream
public void suppress()
Copyright © 2013–2018 The Apache Software Foundation. All rights reserved.