Package org.apache.druid.segment.transform

Class TransformingStringInputRowParser

java.lang.Object

org.apache.druid.data.input.impl.StringInputRowParser

org.apache.druid.segment.transform.TransformingStringInputRowParser

All Implemented Interfaces:

ByteBufferInputRowParser, InputRowParser<ByteBuffer>

public class TransformingStringInputRowParser
extends StringInputRowParser

Constructor Summary

Constructors

Constructor	Description
TransformingStringInputRowParser(ParseSpec parseSpec, String encoding, TransformSpec transformSpec)

Method Summary

Modifier and Type	Method	Description
InputRow	parse(String input)
List<InputRow>	parseBatch(ByteBuffer input)	Parse an input into list of InputRow.
StringInputRowParser	withParseSpec(ParseSpec parseSpec)

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

buildStringKeyMap, getEncoding, getParseSpec, initializeParser, parseString, startFileFromBeginning

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.data.input.impl.InputRowParser

parse

Constructor Details

TransformingStringInputRowParser

public TransformingStringInputRowParser(ParseSpec parseSpec,
 String encoding,
 TransformSpec transformSpec)

Method Details

parseBatch

public List<InputRow> parseBatch(ByteBuffer input)

Description copied from interface: InputRowParser

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.

Specified by:

parseBatch in interface InputRowParser<ByteBuffer>

Overrides:

parseBatch in class StringInputRowParser

parse

@Nullable
public InputRow parse(@Nullable
 String input)

Overrides:

parse in class StringInputRowParser

withParseSpec

public StringInputRowParser withParseSpec(ParseSpec parseSpec)

Specified by:

withParseSpec in interface ByteBufferInputRowParser

Specified by:

withParseSpec in interface InputRowParser<ByteBuffer>

Overrides:

withParseSpec in class StringInputRowParser