public class ColumnWriteStoreImpl extends Object implements ColumnWriteStore
Constructor and Description |
---|
ColumnWriteStoreImpl(PageWriteStore pageWriteStore,
int pageSizeThreshold,
int initialSizePerCol,
int dictionaryPageSizeThreshold,
boolean enableDictionary,
ParquetProperties.WriterVersion writerVersion) |
Modifier and Type | Method and Description |
---|---|
long |
allocatedSize() |
void |
flush()
when we are done writing to flush to the underlying storage
|
Set<ColumnDescriptor> |
getColumnDescriptors() |
ColumnWriter |
getColumnWriter(ColumnDescriptor path) |
long |
maxColMemSize() |
long |
memSize() |
String |
memUsageString() |
String |
toString() |
public ColumnWriteStoreImpl(PageWriteStore pageWriteStore, int pageSizeThreshold, int initialSizePerCol, int dictionaryPageSizeThreshold, boolean enableDictionary, ParquetProperties.WriterVersion writerVersion)
public ColumnWriter getColumnWriter(ColumnDescriptor path)
getColumnWriter
in interface ColumnWriteStore
path
- the column for which to create a writerpublic Set<ColumnDescriptor> getColumnDescriptors()
public long allocatedSize()
public long memSize()
public long maxColMemSize()
public void flush()
ColumnWriteStore
flush
in interface ColumnWriteStore
public String memUsageString()
Copyright © 2015. All rights reserved.