Package | Description |
---|---|
parquet.column | |
parquet.column.page | |
parquet.column.values | |
parquet.column.values.bitpacking | |
parquet.column.values.boundedint | |
parquet.column.values.delta | |
parquet.column.values.deltalengthbytearray | |
parquet.column.values.deltastrings | |
parquet.column.values.dictionary | |
parquet.column.values.plain | |
parquet.column.values.rle | |
parquet.format.converter | |
parquet.hadoop |
Provides classes to store use Parquet files in Hadoop
In a map reduce job:
|
parquet.hadoop.metadata |
Modifier and Type | Method and Description |
---|---|
Encoding |
Dictionary.getEncoding() |
static Encoding |
Encoding.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Encoding[] |
Encoding.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
Dictionary(Encoding encoding) |
Modifier and Type | Method and Description |
---|---|
Encoding |
Page.getDlEncoding() |
Encoding |
DictionaryPage.getEncoding() |
Encoding |
Page.getRlEncoding() |
Encoding |
Page.getValueEncoding() |
Modifier and Type | Method and Description |
---|---|
void |
PageWriter.writePage(BytesInput bytesInput,
int valueCount,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding)
Deprecated.
|
void |
PageWriter.writePage(BytesInput bytesInput,
int valueCount,
Statistics statistics,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding)
writes a single page
|
Constructor and Description |
---|
DictionaryPage(BytesInput bytes,
int dictionarySize,
Encoding encoding)
creates an uncompressed page
|
DictionaryPage(BytesInput bytes,
int uncompressedSize,
int dictionarySize,
Encoding encoding)
creates a dictionary page
|
Page(BytesInput bytes,
int valueCount,
int uncompressedSize,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding)
Deprecated.
|
Page(BytesInput bytes,
int valueCount,
int uncompressedSize,
Statistics stats,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding) |
Modifier and Type | Method and Description |
---|---|
abstract Encoding |
ValuesWriter.getEncoding()
called after getBytes() and before reset()
|
Modifier and Type | Method and Description |
---|---|
Encoding |
BitPackingValuesWriter.getEncoding() |
Encoding |
ByteBitPackingValuesWriter.getEncoding() |
Modifier and Type | Method and Description |
---|---|
Encoding |
DevNullValuesWriter.getEncoding() |
Modifier and Type | Method and Description |
---|---|
Encoding |
DeltaBinaryPackingValuesWriter.getEncoding() |
Modifier and Type | Method and Description |
---|---|
Encoding |
DeltaLengthByteArrayValuesWriter.getEncoding() |
Modifier and Type | Method and Description |
---|---|
Encoding |
DeltaByteArrayWriter.getEncoding() |
Modifier and Type | Method and Description |
---|---|
Encoding |
DictionaryValuesWriter.getEncoding() |
Modifier and Type | Method and Description |
---|---|
Encoding |
FixedLenByteArrayPlainValuesWriter.getEncoding() |
Encoding |
BooleanPlainValuesWriter.getEncoding() |
Encoding |
PlainValuesWriter.getEncoding() |
Modifier and Type | Method and Description |
---|---|
Encoding |
RunLengthBitPackingHybridValuesWriter.getEncoding() |
Modifier and Type | Method and Description |
---|---|
Encoding |
ParquetMetadataConverter.getEncoding(parquet.format.Encoding encoding) |
Modifier and Type | Method and Description |
---|---|
parquet.format.Encoding |
ParquetMetadataConverter.getEncoding(Encoding encoding) |
void |
ParquetMetadataConverter.writeDataPageHeader(int uncompressedSize,
int compressedSize,
int valueCount,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding,
OutputStream to)
Deprecated.
|
void |
ParquetMetadataConverter.writeDataPageHeader(int uncompressedSize,
int compressedSize,
int valueCount,
Statistics statistics,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding,
OutputStream to) |
void |
ParquetMetadataConverter.writeDictionaryPageHeader(int uncompressedSize,
int compressedSize,
int valueCount,
Encoding valuesEncoding,
OutputStream to) |
Modifier and Type | Method and Description |
---|---|
void |
ParquetFileWriter.writeDataPage(int valueCount,
int uncompressedPageSize,
BytesInput bytes,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding)
Deprecated.
|
void |
ParquetFileWriter.writeDataPage(int valueCount,
int uncompressedPageSize,
BytesInput bytes,
Statistics statistics,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding)
writes a single page
|
Modifier and Type | Method and Description |
---|---|
Set<Encoding> |
ColumnChunkProperties.getEncodings() |
Set<Encoding> |
ColumnChunkMetaData.getEncodings() |
Iterator<Encoding> |
EncodingList.iterator() |
List<Encoding> |
EncodingList.toList() |
Modifier and Type | Method and Description |
---|---|
static ColumnChunkProperties |
ColumnChunkProperties.get(ColumnPath path,
PrimitiveType.PrimitiveTypeName type,
CompressionCodecName codec,
Set<Encoding> encodings) |
static ColumnChunkMetaData |
ColumnChunkMetaData.get(ColumnPath path,
PrimitiveType.PrimitiveTypeName type,
CompressionCodecName codec,
Set<Encoding> encodings,
long firstDataPage,
long dictionaryPageOffset,
long valueCount,
long totalSize,
long totalUncompressedSize)
Deprecated.
|
static ColumnChunkMetaData |
ColumnChunkMetaData.get(ColumnPath path,
PrimitiveType.PrimitiveTypeName type,
CompressionCodecName codec,
Set<Encoding> encodings,
Statistics statistics,
long firstDataPage,
long dictionaryPageOffset,
long valueCount,
long totalSize,
long totalUncompressedSize) |
static EncodingList |
EncodingList.getEncodingList(List<Encoding> encodings) |
Copyright © 2015. All rights reserved.