Package org.apache.flink.orc.nohive.writer

Class NoHivePhysicalWriterImpl

java.lang.Object

org.apache.flink.orc.writer.PhysicalWriterImpl

org.apache.flink.orc.nohive.writer.NoHivePhysicalWriterImpl

All Implemented Interfaces:

org.apache.orc.PhysicalWriter

public class NoHivePhysicalWriterImpl
extends org.apache.flink.orc.writer.PhysicalWriterImpl

Protobuf is relocated in orc-core-nohive, therefore method calls involving PB classes need to use the relocated class names here.

Nested Class Summary

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

org.apache.orc.PhysicalWriter.OutputReceiver

Field Summary

Fields inherited from class org.apache.flink.orc.writer.PhysicalWriterImpl

writer

Constructor Summary

Constructors

Constructor	Description
NoHivePhysicalWriterImpl(org.apache.flink.core.fs.FSDataOutputStream out, org.apache.orc.OrcFile.WriterOptions opts)

Method Summary

Modifier and Type	Method	Description
protected void	writeFileFooter(org.apache.orc.OrcProto.Footer footer)
protected void	writeMetadata(org.apache.orc.OrcProto.Metadata metadata)
protected void	writeStripeFooter(org.apache.orc.OrcProto.StripeFooter footer)

Methods inherited from class org.apache.flink.orc.writer.PhysicalWriterImpl

appendRawStripe, close, createDataStream, finalizeStripe, flush, getCompressionCodec, getFileBytes, writeBloomFilter, writeFileFooter, writeFileMetadata, writeHeader, writeIndex, writePostScript

Methods inherited from class java.lang.Object

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

Constructor Detail

NoHivePhysicalWriterImpl

public NoHivePhysicalWriterImpl(org.apache.flink.core.fs.FSDataOutputStream out,
                                org.apache.orc.OrcFile.WriterOptions opts)
                         throws IOException

Throws:

IOException

Method Detail

writeMetadata

protected void writeMetadata(org.apache.orc.OrcProto.Metadata metadata)
                      throws IOException

Overrides:

writeMetadata in class org.apache.flink.orc.writer.PhysicalWriterImpl

Throws:

IOException

writeFileFooter

protected void writeFileFooter(org.apache.orc.OrcProto.Footer footer)
                        throws IOException

Overrides:

writeFileFooter in class org.apache.flink.orc.writer.PhysicalWriterImpl

Throws:

IOException

writeStripeFooter

protected void writeStripeFooter(org.apache.orc.OrcProto.StripeFooter footer)
                          throws IOException

Overrides:

writeStripeFooter in class org.apache.flink.orc.writer.PhysicalWriterImpl

Throws:

IOException