Package org.apache.nifi.processors.standard

Class ValidateCsv.NifiCsvListReader

java.lang.Object
org.supercsv.io.AbstractCsvReader
org.supercsv.io.CsvListReader
org.apache.nifi.processors.standard.ValidateCsv.NifiCsvListReader
All Implemented Interfaces:
Closeable, AutoCloseable, org.supercsv.io.ICsvListReader, org.supercsv.io.ICsvReader
Enclosing class:
ValidateCsv
private class ValidateCsv.NifiCsvListReader extends org.supercsv.io.CsvListReader
This is required to avoid the side effect of Parse* cell processors. If not overriding this method, parsing will return objects and writing objects could result in a different output in comparison to the input.

  • Constructor Summary

    Constructors
    Constructor
    Description
    NifiCsvListReader(Reader reader, org.supercsv.prefs.CsvPreference preferences)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    private void
    executeCellProcessors(List<Object> destination, List<?> source, org.supercsv.cellprocessor.ift.CellProcessor[] processors, int lineNo, int rowNo, boolean includeAllViolations)
     
    protected List<Object>
    executeProcessors(List<Object> processedColumns, org.supercsv.cellprocessor.ift.CellProcessor[] processors, boolean includeAllViolations)
     
    List<Object>
    read(boolean includeAllViolations, org.supercsv.cellprocessor.ift.CellProcessor... processors)
     

    Methods inherited from class org.supercsv.io.CsvListReader

    executeProcessors, read, read

    Methods inherited from class org.supercsv.io.AbstractCsvReader

    close, executeProcessors, get, getColumns, getHeader, getLineNumber, getPreferences, getRowNumber, getUntokenizedRow, length, readRow

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface java.io.Closeable

    close

    Methods inherited from interface org.supercsv.io.ICsvReader

    get, getHeader, getLineNumber, getRowNumber, getUntokenizedRow, length

  • Constructor Details

    • NifiCsvListReader

      public NifiCsvListReader(Reader reader, org.supercsv.prefs.CsvPreference preferences)

  • Method Details

    • read

      public List<Object> read(boolean includeAllViolations, org.supercsv.cellprocessor.ift.CellProcessor... processors) throws IOException
      Throws:
      IOException

    • executeProcessors

      protected List<Object> executeProcessors(List<Object> processedColumns, org.supercsv.cellprocessor.ift.CellProcessor[] processors, boolean includeAllViolations)

    • executeCellProcessors

      private void executeCellProcessors(List<Object> destination, List<?> source, org.supercsv.cellprocessor.ift.CellProcessor[] processors, int lineNo, int rowNo, boolean includeAllViolations)