io.druid.data.input.impl

Interface InputRowParser<T>

All Known Subinterfaces:

ByteBufferInputRowParser

All Known Implementing Classes:

AvroHadoopInputRowParser, AvroStreamInputRowParser, HadoopyStringInputRowParser, IrcInputRowParser, MapInputRowParser, NoopInputRowParser, OrcHadoopInputRowParser, ParquetHadoopInputRowParser, ProtobufInputRowParser, StringInputRowParser, ThriftInputRowParser, TransformingInputRowParser, TransformingStringInputRowParser

public interface InputRowParser<T>

Method Summary

Modifier and Type	Method and Description
ParseSpec	getParseSpec()
default InputRow	parse(T input) Deprecated.
default List<InputRow>	parseBatch(T input) Parse an input into list of InputRow.
InputRowParser	withParseSpec(ParseSpec parseSpec)

Method Detail

parseBatch

@NotNull
default List<InputRow> parseBatch(T input)

Parse an input into list of InputRow. List can contains null for rows that should be thrown away, or throws ParseException if the input is unparseable. This method should never return null otherwise lots of things will break.

parse

@Deprecated
 @Nullable
default InputRow parse(T input)

Deprecated.

Parse an input into an InputRow. Return null if this input should be thrown away, or throws ParseException if the input is unparseable.

getParseSpec

ParseSpec getParseSpec()

withParseSpec

InputRowParser withParseSpec(ParseSpec parseSpec)