org.apache.ignite.internal.processors.bulkload.pipeline

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[]>

A PipelineBlock, which splits line according to CSV format rules and unquotes fields. The next block PipelineBlock.accept(Object, boolean) is called per-line.

Field Summary

Fields

Modifier and Type	Field and Description
static String[]	EMPTY_STR_ARRAY Empty string array.

Constructor Summary

Constructors

Constructor and Description
CsvLineProcessorBlock(BulkLoadCsvFormat format) Creates a CSV line parser.

Method Summary

Modifier and Type	Method and Description
void	accept(String input, boolean isLastPortion) Accepts a portion of input.

Methods inherited from class org.apache.ignite.internal.processors.bulkload.pipeline.PipelineBlock

append

Methods inherited from class java.lang.Object

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

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. isLastPortion parameter 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 with isLastPortion == true is the last one.

Specified by:

accept in class PipelineBlock<String,String[]>

Parameters:

input - Portion of input.

isLastPortion - Is this the last portion.

Throws:

IgniteCheckedException - On error.