Uses of Interface
org.apache.druid.data.input.InputRow

Packages that use InputRow

Package	Description
org.apache.druid.data.input
org.apache.druid.data.input.impl
org.apache.druid.data.input.impl.systemfield
org.apache.druid.segment.generator
org.apache.druid.segment.incremental
org.apache.druid.segment.serde
org.apache.druid.segment.transform
org.apache.druid.timeline.partition

Uses of InputRow in org.apache.druid.data.input

Classes in org.apache.druid.data.input that implement InputRow

Modifier and Type	Class	Description
class	ListBasedInputRow	Input row backed by a List.
class	MapBasedInputRow

Methods in org.apache.druid.data.input that return InputRow

Modifier and Type	Method	Description
InputRow	HandlingInputRowIterator.next()
static InputRow	ListBasedInputRow.parse(RowSignature signature, TimestampSpec timestampSpec, List<String> dimensions, List<Object> data)	Create a row and parse a timestamp.

Methods in org.apache.druid.data.input that return types with arguments of type InputRow

Modifier and Type	Method	Description
Function<InputRow,Object>	ListBasedInputRowAdapter.columnFunction(String columnName)
default RowAdapter<InputRow>	InputFormat.createRowAdapter(InputRowSchema inputRowSchema)	Returns an adapter that can read the rows from InputFormat.createReader(InputRowSchema, InputEntity, File), given a particular InputRowSchema.
List<InputRow>	InputRowListPlusRawValues.getInputRows()
protected abstract List<InputRow>	IntermediateRowParsingReader.parseInputRows(T intermediateRow)	Parses the given intermediate row into a list of InputRows.
abstract List<InputRow>	TextReader.parseInputRows(T intermediateRow)	Parses the given line into a list of InputRows.
CloseableIterator<InputRow>	InputEntityReader.read()
default CloseableIterator<InputRow>	InputSourceReader.read()
CloseableIterator<InputRow>	InputSourceReader.read(InputStats inputStats)
CloseableIterator<InputRow>	IntermediateRowParsingReader.read()
default RowAdapter<InputRow>	InputSourceReader.rowAdapter()	Returns an adapter that can be used to read the rows from InputSourceReader.read().
ToLongFunction<InputRow>	ListBasedInputRowAdapter.timestampFunction()

Methods in org.apache.druid.data.input with parameters of type InputRow

Modifier and Type	Method	Description
boolean	HandlingInputRowIterator.InputRowHandler.handle(InputRow inputRow)
static InputRowListPlusRawValues	InputRowListPlusRawValues.of(InputRow inputRow, Map<String,Object> rawColumns)
static List<Object>	Rows.toGroupKey(long timeStamp, InputRow inputRow)

Method parameters in org.apache.druid.data.input with type arguments of type InputRow

Modifier and Type	Method	Description
static InputRowListPlusRawValues	InputRowListPlusRawValues.of(List<InputRow> inputRows, Map<String,Object> rawColumns)

Constructor parameters in org.apache.druid.data.input with type arguments of type InputRow

Modifier	Constructor	Description
	HandlingInputRowIterator(CloseableIterator<InputRow> inputRowIterator, List<HandlingInputRowIterator.InputRowHandler> inputRowHandlers)

Uses of InputRow in org.apache.druid.data.input.impl

Methods in org.apache.druid.data.input.impl that return InputRow

Modifier and Type	Method	Description
default InputRow	InputRowParser.parse(T input)	Deprecated.
static InputRow	MapInputRowParser.parse(TimestampSpec timestampSpec, List<String> dimensions, Map<String,Object> theMap)
static InputRow	MapInputRowParser.parse(InputRowSchema inputRowSchema, Map<String,Object> theMap)
InputRow	StringInputRowParser.parse(String input)

Methods in org.apache.druid.data.input.impl that return types with arguments of type InputRow

Modifier and Type	Method	Description
RowAdapter<InputRow>	FlatTextInputFormat.createRowAdapter(InputRowSchema inputRowSchema)
default @NotNull List<InputRow>	InputRowParser.parseBatch(T input)	Deprecated. Parse an input into list of InputRow.
List<InputRow>	MapInputRowParser.parseBatch(Map<String,Object> theMap)
List<InputRow>	NoopInputRowParser.parseBatch(InputRow input)
List<InputRow>	StringInputRowParser.parseBatch(ByteBuffer input)
List<InputRow>	DelimitedValueReader.parseInputRows(byte[] line)
List<InputRow>	JsonLineReader.parseInputRows(byte[] line)
protected List<InputRow>	JsonNodeReader.parseInputRows(com.fasterxml.jackson.databind.JsonNode intermediateRow)
protected List<InputRow>	JsonReader.parseInputRows(InputEntity entity)
List<InputRow>	LinesReader.parseInputRows(String intermediateRow)
List<InputRow>	RegexReader.parseInputRows(String intermediateRow)
CloseableIterator<InputRow>	InputEntityIteratingReader.read(InputStats inputStats)
CloseableIterator<InputRow>	TimedShutoffInputSourceReader.read(InputStats inputStats)
RowAdapter<InputRow>	InputEntityIteratingReader.rowAdapter()
RowAdapter<InputRow>	TimedShutoffInputSourceReader.rowAdapter()

Methods in org.apache.druid.data.input.impl with parameters of type InputRow

Modifier and Type	Method	Description
List<InputRow>	NoopInputRowParser.parseBatch(InputRow input)

Uses of InputRow in org.apache.druid.data.input.impl.systemfield

Methods in org.apache.druid.data.input.impl.systemfield that return types with arguments of type InputRow

Modifier and Type	Method	Description
Function<InputRow,InputRow>	SystemFieldDecoratorFactory.decorator(InputEntity entity)	Create a decorator for the given InputEntity.
Function<InputRow,InputRow>	SystemFieldDecoratorFactory.decorator(InputEntity entity)	Create a decorator for the given InputEntity.

Uses of InputRow in org.apache.druid.segment.generator

Methods in org.apache.druid.segment.generator that return InputRow

Modifier and Type	Method	Description
InputRow	DataGenerator.nextRow()

Methods in org.apache.druid.segment.generator that return types with arguments of type InputRow

Modifier and Type	Method	Description
List<InputRow>	DataGenerator.toList(int numOfRows)	Put rows from this generator to a list.

Method parameters in org.apache.druid.segment.generator with type arguments of type InputRow

Modifier and Type	Method	Description
static void	DataGenerator.addStreamToIndex(Stream<InputRow> stream, IncrementalIndex index)	Add rows from any generator to an index.

Uses of InputRow in org.apache.druid.segment.incremental

Methods in org.apache.druid.segment.incremental that return InputRow

Modifier and Type	Method	Description
InputRow	SpatialDimensionRowTransformer.apply(InputRow row)
InputRow	IncrementalIndex.formatRow(InputRow row)
InputRow	IncrementalIndex.InputRowHolder.getRow()

Methods in org.apache.druid.segment.incremental with parameters of type InputRow

Modifier and Type	Method	Description
IncrementalIndexAddResult	IncrementalIndex.add(InputRow row)	Adds a new row.
void	OnHeapAggregateProjection.addToFacts(IncrementalIndexRow key, InputRow inputRow, List<String> parseExceptionMessages, AtomicLong totalSizeInBytes)	Add row to projection OnHeapAggregateProjection.factsHolder, updating totalSizeInBytes estimate
InputRow	SpatialDimensionRowTransformer.apply(InputRow row)
InputRow	IncrementalIndex.formatRow(InputRow row)
static ParseException	IncrementalIndex.getCombinedParseException(InputRow row, List<String> dimParseExceptionMessages, List<String> aggParseExceptionMessages)
void	IncrementalIndex.InputRowHolder.set(InputRow row)

Uses of InputRow in org.apache.druid.segment.serde

Methods in org.apache.druid.segment.serde with parameters of type InputRow

Modifier and Type	Method	Description
T	ComplexMetricExtractor.extractValue(InputRow inputRow, String metricName)
default T	ComplexMetricExtractor.extractValue(InputRow inputRow, String metricName, AggregatorFactory agg)

Uses of InputRow in org.apache.druid.segment.transform

Classes in org.apache.druid.segment.transform that implement InputRow

Modifier and Type	Class	Description
class	TransformedInputRow

Methods in org.apache.druid.segment.transform that return InputRow

Modifier and Type	Method	Description
InputRow	TransformedInputRow.getBaseRow()
InputRow	TransformingStringInputRowParser.parse(String input)
InputRow	Transformer.transform(InputRow row)	Transforms an input row, or returns null if the row should be filtered out.

Methods in org.apache.druid.segment.transform that return types with arguments of type InputRow

Modifier and Type	Method	Description
List<InputRow>	TransformingInputRowParser.parseBatch(T row)
List<InputRow>	TransformingStringInputRowParser.parseBatch(ByteBuffer input)
CloseableIterator<InputRow>	TransformingInputEntityReader.read()
CloseableIterator<InputRow>	TransformingInputSourceReader.read(InputStats inputStats)

Methods in org.apache.druid.segment.transform with parameters of type InputRow

Modifier and Type	Method	Description
InputRow	Transformer.transform(InputRow row)	Transforms an input row, or returns null if the row should be filtered out.

Constructors in org.apache.druid.segment.transform with parameters of type InputRow

Modifier	Constructor	Description
	TransformedInputRow(InputRow row, Map<String,RowFunction> transforms)

Uses of InputRow in org.apache.druid.timeline.partition

Methods in org.apache.druid.timeline.partition with parameters of type InputRow

Modifier and Type	Method	Description
static List<Object>	HashPartitioner.extractKeys(List<String> partitionDimensions, long timestamp, InputRow inputRow)
protected static StringTuple	BaseDimensionRangeShardSpec.getInputRowTuple(List<String> dimensions, InputRow inputRow)
ShardSpec	ShardSpecLookup.getShardSpec(long timestamp, InputRow row)	Returns a ShardSpec for the given timestamp and the inputRow.