Package parquet.hadoop.CodecFactory

Examples of parquet.hadoop.CodecFactory.BytesCompressor

26
27
28
29
30
31
32
33
import java.io.IOException;

public class ColumnChunkPageWriteStoreExposer {

  public static ColumnChunkPageWriteStore newColumnChunkPageWriteStore(CompressionCodecName codec, int pageSize, MessageType schema, int initialSize) {
    BytesCompressor compressor = new CodecFactory(new Configuration()).getCompressor(codec, pageSize);
    return new ColumnChunkPageWriteStore(compressor, schema, initialSize);
  }
View Full Code Here
33
34
35
36
37
38
39
40
  public static ColumnChunkPageWriteStore newColumnChunkPageWriteStore(OperatorContext oContext,
                                                                       CompressionCodecName codec,
                                                                       int pageSize,
                                                                       MessageType schema,
                                                                       int initialSize) {
    BytesCompressor compressor = new CodecFactory(new Configuration()).getCompressor(codec, pageSize);
    return new ColumnChunkPageWriteStore(compressor, schema, initialSize, new ParquetDirectByteBufferAllocator(oContext));
  }
View Full Code Here
32
33
34
35
36
37
38
39
  public static ColumnChunkPageWriteStore newColumnChunkPageWriteStore(OperatorContext oContext,
                                                                       CompressionCodecName codec,
                                                                       int pageSize,
                                                                       MessageType schema,
                                                                       int initialSize) {
    BytesCompressor compressor = new CodecFactory(new Configuration()).getCompressor(codec, pageSize);
    return new ColumnChunkPageWriteStore(compressor, schema, initialSize, new ParquetDirectByteBufferAllocator(oContext));
  }
View Full Code Here
TOP

Related Classes of parquet.hadoop.CodecFactory.BytesCompressor

  • parquet.hadoop.ColumnChunkPageWriteStoreExposer
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.