Package org.apache.orc.impl.writer

Class StringBaseTreeWriter

java.lang.Object

org.apache.orc.impl.writer.TreeWriterBase

org.apache.orc.impl.writer.StringBaseTreeWriter

All Implemented Interfaces:

TreeWriter

Direct Known Subclasses:

CharTreeWriter, StringTreeWriter, VarcharTreeWriter

public abstract class StringBaseTreeWriter
extends TreeWriterBase

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.orc.impl.writer.TreeWriter

TreeWriter.Factory

Field Summary

Fields

Modifier and Type	Field	Description
protected Dictionary	dictionary
protected final PositionedOutputStream	directStreamOutput
protected final IntegerWriter	lengthOutput
protected final DynamicIntArray	rows
protected boolean	useDictionaryEncoding

Fields inherited from class org.apache.orc.impl.writer.TreeWriterBase

bloomFilter, bloomFilterEntry, bloomFilterUtf8, context, createBloomFilter, encryption, fileStatistics, id, indexStatistics, isPresent, rowIndexPosition, schema, stripeColStatistics

Method Summary

Modifier and Type	Method	Description
void	createRowIndexEntry()	This method doesn't call the super method, because unlike most of the other TreeWriters, this one can't record the position in the streams until the stripe is being flushed.
long	estimateMemory()	Estimate how much memory the writer is consuming excluding the streams.
void	flushStreams()	Flush the TreeWriter stream
long	getRawDataSize()	Estimate the memory used if the file was read into Hive's Writable types.
void	prepareStripe(int stripeId)	Set up for the next stripe.
void	writeStripe(int requiredIndexEntries)	Write the stripe out to the file.

Methods inherited from class org.apache.orc.impl.writer.TreeWriterBase

addStripeStatistics, getCurrentStatistics, getRowIndex, getRowIndexEntry, getStripeStatistics, writeBatch, writeFileStatistics, writeRootBatch

Methods inherited from class java.lang.Object

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

Field Details

lengthOutput

protected final IntegerWriter lengthOutput

rows

protected final DynamicIntArray rows

directStreamOutput

protected final PositionedOutputStream directStreamOutput

dictionary

protected Dictionary dictionary

useDictionaryEncoding

protected boolean useDictionaryEncoding

Method Details

writeStripe

public void writeStripe(int requiredIndexEntries)
                 throws IOException

Description copied from interface: TreeWriter

Write the stripe out to the file.

Specified by:

writeStripe in interface TreeWriter

Overrides:

writeStripe in class TreeWriterBase

Parameters:

requiredIndexEntries - the number of index entries that are required. this is to check to make sure the row index is well formed.

Throws:

IOException

createRowIndexEntry

public void createRowIndexEntry()
                         throws IOException

This method doesn't call the super method, because unlike most of the other TreeWriters, this one can't record the position in the streams until the stripe is being flushed. Therefore it saves all of the entries and augments them with the final information as the stripe is written.

Specified by:

createRowIndexEntry in interface TreeWriter

Overrides:

createRowIndexEntry in class TreeWriterBase

Throws:

IOException

estimateMemory

public long estimateMemory()

Description copied from class: TreeWriterBase

Estimate how much memory the writer is consuming excluding the streams.

Specified by:

estimateMemory in interface TreeWriter

Overrides:

estimateMemory in class TreeWriterBase

Returns:

the number of bytes.

getRawDataSize

public long getRawDataSize()

Description copied from interface: TreeWriter

Estimate the memory used if the file was read into Hive's Writable types. This is used as an estimate for the query optimizer.

Returns:

the number of bytes

flushStreams

public void flushStreams()
                  throws IOException

Description copied from interface: TreeWriter

Flush the TreeWriter stream

Specified by:

flushStreams in interface TreeWriter

Overrides:

flushStreams in class TreeWriterBase

Throws:

IOException

prepareStripe

public void prepareStripe(int stripeId)

Description copied from interface: TreeWriter

Set up for the next stripe.

Specified by:

prepareStripe in interface TreeWriter

Overrides:

prepareStripe in class TreeWriterBase

Parameters:

stripeId - the next stripe id