Package cz.o2.proxima.direct.io.bulkfs.parquet

Class StreamElementWriteSupport

  • @Internal
public class StreamElementWriteSupport
extends org.apache.parquet.hadoop.api.WriteSupport<StreamElement>

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.parquet.hadoop.api.WriteSupport

        org.apache.parquet.hadoop.api.WriteSupport.FinalizedWriteContext, org.apache.parquet.hadoop.api.WriteSupport.WriteContext

    • Constructor Summary

      Constructors 
      Constructor Description
      StreamElementWriteSupport​(org.apache.parquet.schema.MessageType parquetSchema, java.lang.String attributeNamesPrefix)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.parquet.hadoop.api.WriteSupport.WriteContext init​(org.apache.hadoop.conf.Configuration configuration)  
      void prepareForWrite​(org.apache.parquet.io.api.RecordConsumer recordConsumer)  
      void write​(StreamElement record)  

      • Methods inherited from class org.apache.parquet.hadoop.api.WriteSupport

        finalizeWrite, getName

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • StreamElementWriteSupport

        public StreamElementWriteSupport​(org.apache.parquet.schema.MessageType parquetSchema,
                                 java.lang.String attributeNamesPrefix)

    • Method Detail

      • init

        public org.apache.parquet.hadoop.api.WriteSupport.WriteContext init​(org.apache.hadoop.conf.Configuration configuration)
        Specified by:
        init in class org.apache.parquet.hadoop.api.WriteSupport<StreamElement>

      • prepareForWrite

        public void prepareForWrite​(org.apache.parquet.io.api.RecordConsumer recordConsumer)
        Specified by:
        prepareForWrite in class org.apache.parquet.hadoop.api.WriteSupport<StreamElement>

      • write

        public void write​(StreamElement record)
        Specified by:
        write in class org.apache.parquet.hadoop.api.WriteSupport<StreamElement>