public static class SerDeEncodedDataReader.CacheWriter extends Object implements org.apache.orc.PhysicalWriter
Constructor and Description |
---|
CacheWriter(BufferUsageManager bufferManager,
List<Integer> columnIds,
boolean[] writerIncludes,
boolean doesSourceHaveIncludes) |
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() |
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) |
public CacheWriter(BufferUsageManager bufferManager, List<Integer> columnIds, boolean[] writerIncludes, boolean doesSourceHaveIncludes)
public void writeFileMetadata(org.apache.orc.OrcProto.Metadata.Builder builder) throws IOException
writeFileMetadata
in interface org.apache.orc.PhysicalWriter
IOException
public void writeFileFooter(org.apache.orc.OrcProto.Footer.Builder builder) throws IOException
writeFileFooter
in interface org.apache.orc.PhysicalWriter
IOException
public void validateIncludes(org.apache.orc.OrcProto.Footer footer) throws IOException
IOException
public long writePostScript(org.apache.orc.OrcProto.PostScript.Builder builder)
writePostScript
in interface org.apache.orc.PhysicalWriter
public void close() throws IOException
close
in interface org.apache.orc.PhysicalWriter
IOException
public void discardData()
public org.apache.orc.PhysicalWriter.OutputReceiver createDataStream(org.apache.orc.impl.StreamName name) throws IOException
createDataStream
in interface org.apache.orc.PhysicalWriter
IOException
public void writeHeader() throws IOException
writeHeader
in interface org.apache.orc.PhysicalWriter
IOException
public void writeIndex(org.apache.orc.impl.StreamName name, org.apache.orc.OrcProto.RowIndex.Builder index, org.apache.orc.CompressionCodec codec) throws IOException
writeIndex
in interface org.apache.orc.PhysicalWriter
IOException
public void writeBloomFilter(org.apache.orc.impl.StreamName name, org.apache.orc.OrcProto.BloomFilterIndex.Builder bloom, org.apache.orc.CompressionCodec codec) throws IOException
writeBloomFilter
in interface org.apache.orc.PhysicalWriter
IOException
public void finalizeStripe(org.apache.orc.OrcProto.StripeFooter.Builder footer, org.apache.orc.OrcProto.StripeInformation.Builder dirEntry) throws IOException
finalizeStripe
in interface org.apache.orc.PhysicalWriter
IOException
public void flush() throws IOException
flush
in interface org.apache.orc.PhysicalWriter
IOException
public void appendRawStripe(ByteBuffer stripe, org.apache.orc.OrcProto.StripeInformation.Builder dirEntry) throws IOException
appendRawStripe
in interface org.apache.orc.PhysicalWriter
IOException
public org.apache.orc.CompressionCodec getCompressionCodec()
getCompressionCodec
in interface org.apache.orc.PhysicalWriter
public void setCurrentStripeOffsets(long currentKnownTornStart, long firstStartOffset, long lastStartOffset, long currentFileOffset)
Copyright © 2021 The Apache Software Foundation. All rights reserved.