Class AbstractBatchedColumnProcessor<T extends Context>

    • Constructor Summary

      Constructors 
      Constructor Description
      AbstractBatchedColumnProcessor​(int rowsPerBatch)
      Constructs a batched column processor configured to invoke the batchesProcessed method after a given number of rows has been processed.
    • Constructor Detail

      • AbstractBatchedColumnProcessor

        public AbstractBatchedColumnProcessor​(int rowsPerBatch)
        Constructs a batched column processor configured to invoke the batchesProcessed method after a given number of rows has been processed.
        Parameters:
        rowsPerBatch - the number of rows to process in each batch.
    • Method Detail

      • processStarted

        public void processStarted​(T context)
        Description copied from interface: Processor
        This method will by invoked by the parser once, when it is ready to start processing the input.
        Specified by:
        processStarted in interface Processor<T extends Context>
        Parameters:
        context - A contextual object with information and controls over the current state of the parsing process
      • rowProcessed

        public void rowProcessed​(java.lang.String[] row,
                                 T context)
        Description copied from interface: Processor
        Invoked by the parser after all values of a valid record have been processed.
        Specified by:
        rowProcessed in interface Processor<T extends Context>
        Parameters:
        row - the data extracted by the parser for an individual record. Note that:
        context - A contextual object with information and controls over the current state of the parsing process
      • processEnded

        public void processEnded​(T context)
        Description copied from interface: Processor
        This method will by invoked by the parser once, after the parsing process stopped and all resources were closed.

        It will always be called by the parser: in case of errors, if the end of the input us reached, or if the user stopped the process manually using Context.stop().

        Specified by:
        processEnded in interface Processor<T extends Context>
        Parameters:
        context - A contextual object with information and controls over the state of the parsing process
      • getHeaders

        public final java.lang.String[] getHeaders()
      • getColumnValuesAsList

        public final java.util.List<java.util.List<java.lang.String>> getColumnValuesAsList()
      • putColumnValuesInMapOfNames

        public final void putColumnValuesInMapOfNames​(java.util.Map<java.lang.String,​java.util.List<java.lang.String>> map)
      • putColumnValuesInMapOfIndexes

        public final void putColumnValuesInMapOfIndexes​(java.util.Map<java.lang.Integer,​java.util.List<java.lang.String>> map)
      • getColumnValuesAsMapOfNames

        public final java.util.Map<java.lang.String,​java.util.List<java.lang.String>> getColumnValuesAsMapOfNames()
      • getColumnValuesAsMapOfIndexes

        public final java.util.Map<java.lang.Integer,​java.util.List<java.lang.String>> getColumnValuesAsMapOfIndexes()
      • getColumn

        public java.util.List<java.lang.String> getColumn​(java.lang.String columnName)
      • getColumn

        public java.util.List<java.lang.String> getColumn​(int columnIndex)
      • getRowsPerBatch

        public int getRowsPerBatch()
      • getBatchesProcessed

        public int getBatchesProcessed()
      • batchProcessed

        public abstract void batchProcessed​(int rowsInThisBatch)