Package org.apache.druid.data.input

Class InputRowSchema

java.lang.Object

org.apache.druid.data.input.InputRowSchema

public class InputRowSchema
extends Object

Schema of InputRow.

Constructor Summary

Constructors

Constructor	Description
InputRowSchema(TimestampSpec timestampSpec, DimensionsSpec dimensionsSpec, ColumnsFilter columnsFilter)
InputRowSchema(TimestampSpec timestampSpec, DimensionsSpec dimensionsSpec, ColumnsFilter columnsFilter, Set<String> metricNames)

Method Summary

Modifier and Type	Method	Description
ColumnsFilter	getColumnsFilter()	A ColumnsFilter that can filter down the list of columns that must be read after flattening.
DimensionsSpec	getDimensionsSpec()
@NotNull Set<String>	getMetricNames()
TimestampSpec	getTimestampSpec()

Methods inherited from class java.lang.Object

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

Constructor Details

InputRowSchema

public InputRowSchema(TimestampSpec timestampSpec,
 DimensionsSpec dimensionsSpec,
 ColumnsFilter columnsFilter)

InputRowSchema

public InputRowSchema(TimestampSpec timestampSpec,
 DimensionsSpec dimensionsSpec,
 ColumnsFilter columnsFilter,
 Set<String> metricNames)

Method Details

getMetricNames

@NotNull
public @NotNull Set<String> getMetricNames()

getTimestampSpec

public TimestampSpec getTimestampSpec()

getDimensionsSpec

public DimensionsSpec getDimensionsSpec()

getColumnsFilter

public ColumnsFilter getColumnsFilter()

A ColumnsFilter that can filter down the list of columns that must be read after flattening. Logically, Druid applies ingestion spec components in a particular order: first flattenSpec (if any), then timestampSpec, then transformSpec, and finally dimensionsSpec and metricsSpec. If a flattenSpec is provided, this method returns a filter that should be applied after flattening. So, it will be based on what needs to pass between the flattenSpec and everything beyond it.