Package edu.stanford.slac.archiverappliance.plain.parquet

Class EpicsParquetWriter

java.lang.Object
org.apache.parquet.hadoop.ParquetWriter<com.google.protobuf.Message>
edu.stanford.slac.archiverappliance.plain.parquet.EpicsParquetWriter
All Implemented Interfaces:
Closeable, AutoCloseable
public class EpicsParquetWriter extends org.apache.parquet.hadoop.ParquetWriter<com.google.protobuf.Message>
A ParquetWriter for EPICS Archiver Appliance data.
Author:
Sky Brewer

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    EpicsParquetWriter.Builder
     

  • Field Summary

    Fields inherited from class org.apache.parquet.hadoop.ParquetWriter

    DEFAULT_BLOCK_SIZE, DEFAULT_COMPRESSION_CODEC_NAME, DEFAULT_IS_DICTIONARY_ENABLED, DEFAULT_IS_VALIDATING_ENABLED, DEFAULT_PAGE_SIZE, DEFAULT_WRITER_VERSION, MAX_PADDING_SIZE_DEFAULT, OBJECT_MODEL_NAME_PROP

  • Constructor Summary

    Constructors
    Constructor
    Description
    EpicsParquetWriter(org.apache.hadoop.fs.Path file, org.apache.parquet.hadoop.api.WriteSupport<com.google.protobuf.Message> writeSupport, org.apache.parquet.hadoop.metadata.CompressionCodecName compressionCodecName, int blockSize, int pageSize)
    The builder for EpicsParquetWriter.

  • Method Summary

    Modifier and Type
    Method
    Description
    static EpicsParquetWriter.Builder
    builder(org.apache.parquet.io.OutputFile file)
    The builder for EpicsParquetWriter.

    Methods inherited from class org.apache.parquet.hadoop.ParquetWriter

    close, getDataSize, getFooter, write

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • EpicsParquetWriter

      public EpicsParquetWriter(org.apache.hadoop.fs.Path file, org.apache.parquet.hadoop.api.WriteSupport<com.google.protobuf.Message> writeSupport, org.apache.parquet.hadoop.metadata.CompressionCodecName compressionCodecName, int blockSize, int pageSize) throws IOException
      The builder for EpicsParquetWriter.
      Parameters:
      file - The file to write to.
      writeSupport - The write support to use.
      compressionCodecName - The compression codec to use.
      blockSize - The block size to use.
      pageSize - The page size to use.
      Throws:
      IOException - If there is an error accessing the file.

  • Method Details