public class ParquetMetadataConverter extends Object
Constructor and Description |
---|
ParquetMetadataConverter() |
Modifier and Type | Method and Description |
---|---|
ParquetMetadata |
fromParquetMetadata(parquet.format.FileMetaData parquetMetadata) |
static Statistics |
fromParquetStatistics(parquet.format.Statistics statistics,
PrimitiveType.PrimitiveTypeName type) |
Encoding |
getEncoding(parquet.format.Encoding encoding) |
parquet.format.Encoding |
getEncoding(Encoding encoding) |
PrimitiveType.PrimitiveTypeName |
getPrimitive(parquet.format.Type type) |
ParquetMetadata |
readParquetMetadata(InputStream from) |
parquet.format.FileMetaData |
toParquetMetadata(int currentVersion,
ParquetMetadata parquetMetadata) |
static parquet.format.Statistics |
toParquetStatistics(Statistics statistics) |
void |
writeDataPageHeader(int uncompressedSize,
int compressedSize,
int valueCount,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding,
OutputStream to)
Deprecated.
|
void |
writeDataPageHeader(int uncompressedSize,
int compressedSize,
int valueCount,
Statistics statistics,
Encoding rlEncoding,
Encoding dlEncoding,
Encoding valuesEncoding,
OutputStream to) |
void |
writeDictionaryPageHeader(int uncompressedSize,
int compressedSize,
int valueCount,
Encoding valuesEncoding,
OutputStream to) |
public parquet.format.FileMetaData toParquetMetadata(int currentVersion, ParquetMetadata parquetMetadata)
public Encoding getEncoding(parquet.format.Encoding encoding)
public parquet.format.Encoding getEncoding(Encoding encoding)
public static parquet.format.Statistics toParquetStatistics(Statistics statistics)
public static Statistics fromParquetStatistics(parquet.format.Statistics statistics, PrimitiveType.PrimitiveTypeName type)
public PrimitiveType.PrimitiveTypeName getPrimitive(parquet.format.Type type)
public ParquetMetadata readParquetMetadata(InputStream from) throws IOException
IOException
public ParquetMetadata fromParquetMetadata(parquet.format.FileMetaData parquetMetadata) throws IOException
IOException
@Deprecated public void writeDataPageHeader(int uncompressedSize, int compressedSize, int valueCount, Encoding rlEncoding, Encoding dlEncoding, Encoding valuesEncoding, OutputStream to) throws IOException
IOException
public void writeDataPageHeader(int uncompressedSize, int compressedSize, int valueCount, Statistics statistics, Encoding rlEncoding, Encoding dlEncoding, Encoding valuesEncoding, OutputStream to) throws IOException
IOException
public void writeDictionaryPageHeader(int uncompressedSize, int compressedSize, int valueCount, Encoding valuesEncoding, OutputStream to) throws IOException
IOException
Copyright © 2015. All rights reserved.