Package io.deephaven.parquet.base

Class ParquetFileWriter

java.lang.Object

io.deephaven.parquet.base.ParquetFileWriter

All Implemented Interfaces:

AutoCloseable

public final class ParquetFileWriter
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
ParquetFileWriter(URI dest, OutputStream destOutputStream, int targetPageSize, org.apache.parquet.bytes.ByteBufferAllocator allocator, org.apache.parquet.schema.MessageType type, String codecName, Map<String,String> extraMetaData, @NotNull ParquetMetadataFileWriter metadataFileWriter)

Method Summary

Modifier and Type	Method	Description
RowGroupWriter	addRowGroup(long size)
long	bytesWritten()	Get the number of bytes written to the parquet file so far.
void	close()
static void	serializeFooter(org.apache.parquet.hadoop.metadata.ParquetMetadata footer, com.google.common.io.CountingOutputStream countingOutput)

Methods inherited from class java.lang.Object

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

Constructor Details

ParquetFileWriter

public ParquetFileWriter(URI dest,
 OutputStream destOutputStream,
 int targetPageSize,
 org.apache.parquet.bytes.ByteBufferAllocator allocator,
 org.apache.parquet.schema.MessageType type,
 String codecName,
 Map<String,String> extraMetaData,
 @NotNull
 @NotNull ParquetMetadataFileWriter metadataFileWriter)
                  throws IOException

Throws:

IOException

Method Details

addRowGroup

public RowGroupWriter addRowGroup(long size)

bytesWritten

public long bytesWritten()

Get the number of bytes written to the parquet file so far.

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

serializeFooter

public static void serializeFooter(org.apache.parquet.hadoop.metadata.ParquetMetadata footer,
 com.google.common.io.CountingOutputStream countingOutput)
                            throws IOException

Throws:

IOException