org.apache.hadoop.hive.llap.io.encoded

Class SerDeEncodedDataReader.CacheWriter

java.lang.Object

org.apache.hadoop.hive.llap.io.encoded.SerDeEncodedDataReader.CacheWriter

All Implemented Interfaces:

org.apache.orc.PhysicalWriter

Enclosing class:

SerDeEncodedDataReader

public static class SerDeEncodedDataReader.CacheWriter
extends Object
implements org.apache.orc.PhysicalWriter

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.orc.PhysicalWriter

org.apache.orc.PhysicalWriter.OutputReceiver

Constructor Summary

Constructors

Constructor and Description
CacheWriter(BufferUsageManager bufferManager, List<Integer> columnIds, boolean[] writerIncludes, boolean doesSourceHaveIncludes, org.apache.hadoop.hive.common.io.Allocator.BufferObjectFactory bufferFactory)

Method Summary

Modifier and Type	Method and Description
void	appendRawStripe(ByteBuffer stripe, org.apache.orc.OrcProto.StripeInformation.Builder dirEntry)
void	close()
org.apache.orc.PhysicalWriter.OutputReceiver	createDataStream(org.apache.orc.impl.StreamName name)
void	discardData()
void	finalizeStripe(org.apache.orc.OrcProto.StripeFooter.Builder footer, org.apache.orc.OrcProto.StripeInformation.Builder dirEntry)
void	flush()
org.apache.orc.CompressionCodec	getCompressionCodec()
long	getFileBytes(int column)
void	setCurrentStripeOffsets(long currentKnownTornStart, long firstStartOffset, long lastStartOffset, long currentFileOffset)
void	validateIncludes(org.apache.orc.OrcProto.Footer footer)
void	writeBloomFilter(org.apache.orc.impl.StreamName name, org.apache.orc.OrcProto.BloomFilterIndex.Builder bloom, org.apache.orc.CompressionCodec codec)
void	writeFileFooter(org.apache.orc.OrcProto.Footer.Builder builder)
void	writeFileMetadata(org.apache.orc.OrcProto.Metadata.Builder builder)
void	writeHeader()
void	writeIndex(org.apache.orc.impl.StreamName name, org.apache.orc.OrcProto.RowIndex.Builder index, org.apache.orc.CompressionCodec codec)
long	writePostScript(org.apache.orc.OrcProto.PostScript.Builder builder)

Methods inherited from class java.lang.Object

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

Constructor Detail

CacheWriter

public CacheWriter(BufferUsageManager bufferManager,
                   List<Integer> columnIds,
                   boolean[] writerIncludes,
                   boolean doesSourceHaveIncludes,
                   org.apache.hadoop.hive.common.io.Allocator.BufferObjectFactory bufferFactory)

Method Detail

writeFileMetadata

public void writeFileMetadata(org.apache.orc.OrcProto.Metadata.Builder builder)
                       throws IOException

Specified by:

writeFileMetadata in interface org.apache.orc.PhysicalWriter

Throws:

IOException

writeFileFooter

public void writeFileFooter(org.apache.orc.OrcProto.Footer.Builder builder)
                     throws IOException

Specified by:

writeFileFooter in interface org.apache.orc.PhysicalWriter

Throws:

IOException

validateIncludes

public void validateIncludes(org.apache.orc.OrcProto.Footer footer)
                      throws IOException

Throws:

IOException

writePostScript

public long writePostScript(org.apache.orc.OrcProto.PostScript.Builder builder)

Specified by:

writePostScript in interface org.apache.orc.PhysicalWriter

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.orc.PhysicalWriter

Throws:

IOException

discardData

public void discardData()

createDataStream

public org.apache.orc.PhysicalWriter.OutputReceiver createDataStream(org.apache.orc.impl.StreamName name)
                                                              throws IOException

Specified by:

createDataStream in interface org.apache.orc.PhysicalWriter

Throws:

IOException

writeHeader

public void writeHeader()
                 throws IOException

Specified by:

writeHeader in interface org.apache.orc.PhysicalWriter

Throws:

IOException

writeIndex

public void writeIndex(org.apache.orc.impl.StreamName name,
                       org.apache.orc.OrcProto.RowIndex.Builder index,
                       org.apache.orc.CompressionCodec codec)
                throws IOException

Specified by:

writeIndex in interface org.apache.orc.PhysicalWriter

Throws:

IOException

writeBloomFilter

public void writeBloomFilter(org.apache.orc.impl.StreamName name,
                             org.apache.orc.OrcProto.BloomFilterIndex.Builder bloom,
                             org.apache.orc.CompressionCodec codec)
                      throws IOException

Specified by:

writeBloomFilter in interface org.apache.orc.PhysicalWriter

Throws:

IOException

finalizeStripe

public void finalizeStripe(org.apache.orc.OrcProto.StripeFooter.Builder footer,
                           org.apache.orc.OrcProto.StripeInformation.Builder dirEntry)
                    throws IOException

Specified by:

finalizeStripe in interface org.apache.orc.PhysicalWriter

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface org.apache.orc.PhysicalWriter

Throws:

IOException

appendRawStripe

public void appendRawStripe(ByteBuffer stripe,
                            org.apache.orc.OrcProto.StripeInformation.Builder dirEntry)
                     throws IOException

Specified by:

appendRawStripe in interface org.apache.orc.PhysicalWriter

Throws:

IOException

setCurrentStripeOffsets

public void setCurrentStripeOffsets(long currentKnownTornStart,
                                    long firstStartOffset,
                                    long lastStartOffset,
                                    long currentFileOffset)

getCompressionCodec

public org.apache.orc.CompressionCodec getCompressionCodec()

Specified by:

getCompressionCodec in interface org.apache.orc.PhysicalWriter

getFileBytes

public long getFileBytes(int column)

Specified by:

getFileBytes in interface org.apache.orc.PhysicalWriter