Package org.apache.druid.data.input.impl

Class CsvInputFormat

java.lang.Object

org.apache.druid.data.input.impl.FlatTextInputFormat

org.apache.druid.data.input.impl.CsvInputFormat

All Implemented Interfaces:

InputFormat

public class CsvInputFormat
extends FlatTextInputFormat

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TYPE_KEY

Fields inherited from interface org.apache.druid.data.input.InputFormat

TYPE_PROPERTY

Constructor Summary

Constructors

Constructor	Description
CsvInputFormat(List<String> columns, String listDelimiter, Boolean hasHeaderRow, Boolean findColumnsFromHeader, int skipHeaderRows, Boolean tryParseNumbers)

Method Summary

Modifier and Type	Method	Description
static com.opencsv.RFC4180Parser	createOpenCsvParser()
InputEntityReader	createReader(InputRowSchema inputRowSchema, InputEntity source, File temporaryDirectory)
String	getDelimiter()
boolean	isSplittable()	Trait to indicate that a file can be split into multiple InputSplits.
String	toString()

Methods inherited from class org.apache.druid.data.input.impl.FlatTextInputFormat

createRowAdapter, equals, fieldsToString, getColumns, getListDelimiter, getSkipHeaderRows, getWeightedSize, hashCode, isFindColumnsFromHeader, shouldTryParseNumbers, useListBasedInputRows

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details

TYPE_KEY

public static final String TYPE_KEY

See Also:

• Constant Field Values

Constructor Details

CsvInputFormat

public CsvInputFormat(@Nullable
 List<String> columns,
 @Nullable
 String listDelimiter,
 @Deprecated @Nullable
 Boolean hasHeaderRow,
 @Nullable
 Boolean findColumnsFromHeader,
 int skipHeaderRows,
 @Nullable
 Boolean tryParseNumbers)

Method Details

getDelimiter

public String getDelimiter()

Overrides:

getDelimiter in class FlatTextInputFormat

isSplittable

public boolean isSplittable()

Description copied from interface: InputFormat

Trait to indicate that a file can be split into multiple InputSplits.

This method is not being used anywhere for now, but should be considered in SplittableInputSource.createSplits(org.apache.druid.data.input.InputFormat, org.apache.druid.data.input.SplitHintSpec) in the future.

createReader

public InputEntityReader createReader(InputRowSchema inputRowSchema,
 InputEntity source,
 File temporaryDirectory)

createOpenCsvParser

public static com.opencsv.RFC4180Parser createOpenCsvParser()

toString

public String toString()

Overrides:

toString in class Object