Class CsvLineProcessorBlock
- java.lang.Object
-
- org.apache.ignite.internal.processors.bulkload.pipeline.PipelineBlock<String,String[]>
-
- org.apache.ignite.internal.processors.bulkload.pipeline.CsvLineProcessorBlock
-
public class CsvLineProcessorBlock extends PipelineBlock<String,String[]>
APipelineBlock, which splits line according to CSV format rules and unquotes fields. The next blockPipelineBlock.accept(Object, boolean)is called per-line.
-
-
Field Summary
Fields Modifier and Type Field Description static String[]EMPTY_STR_ARRAYEmpty string array.
-
Constructor Summary
Constructors Constructor Description CsvLineProcessorBlock(BulkLoadCsvFormat format)Creates a CSV line parser.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaccept(String input, boolean isLastPortion)Accepts a portion of input.-
Methods inherited from class org.apache.ignite.internal.processors.bulkload.pipeline.PipelineBlock
append
-
-
-
-
Field Detail
-
EMPTY_STR_ARRAY
public static final String[] EMPTY_STR_ARRAY
Empty string array.
-
-
Constructor Detail
-
CsvLineProcessorBlock
public CsvLineProcessorBlock(BulkLoadCsvFormat format)
Creates a CSV line parser.
-
-
Method Detail
-
accept
public void accept(String input, boolean isLastPortion) throws IgniteCheckedException
Accepts a portion of input.isLastPortionparameter should be set if this is a last portion of the input. The method must not be called after the end of input: the call withisLastPortion == trueis the last one.- Specified by:
acceptin classPipelineBlock<String,String[]>- Parameters:
input- Portion of input.isLastPortion- Is this the last portion.- Throws:
IgniteCheckedException- On error.
-
-