org.apache.paimon.mosaic

Class MosaicWriter

java.lang.Object

org.apache.paimon.mosaic.MosaicWriter

All Implemented Interfaces:

AutoCloseable

public class MosaicWriter
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor and Description
MosaicWriter(OutputStream outputStream, org.apache.arrow.vector.types.pojo.Schema arrowSchema, org.apache.arrow.memory.BufferAllocator allocator)
MosaicWriter(OutputStream outputStream, org.apache.arrow.vector.types.pojo.Schema arrowSchema, WriterOptions options, org.apache.arrow.memory.BufferAllocator allocator)

Method Summary

Modifier and Type	Method and Description
void	close()
long	estimatedFileSize()
Map<String,ColumnStatistics>	getRowGroupStatistics(int rgIndex) Returns column statistics for the given row group, keyed by column name.
int	numRowGroups()
void	write(org.apache.arrow.vector.VectorSchemaRoot root)

Methods inherited from class java.lang.Object

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

Constructor Detail

MosaicWriter

public MosaicWriter(OutputStream outputStream,
                    org.apache.arrow.vector.types.pojo.Schema arrowSchema,
                    org.apache.arrow.memory.BufferAllocator allocator)

MosaicWriter

public MosaicWriter(OutputStream outputStream,
                    org.apache.arrow.vector.types.pojo.Schema arrowSchema,
                    WriterOptions options,
                    org.apache.arrow.memory.BufferAllocator allocator)

Method Detail

write

public void write(org.apache.arrow.vector.VectorSchemaRoot root)

estimatedFileSize

public long estimatedFileSize()

numRowGroups

public int numRowGroups()

getRowGroupStatistics

public Map<String,ColumnStatistics> getRowGroupStatistics(int rgIndex)

Returns column statistics for the given row group, keyed by column name.

close

public void close()

Specified by:

close in interface AutoCloseable