io.druid.sql.calcite.expression

Class RowExtraction

java.lang.Object

io.druid.sql.calcite.expression.RowExtraction

public class RowExtraction
extends Object

Represents an extraction of a value from a Druid row. Can be used for grouping, filtering, etc. Currently this is a column plus an extractionFn, but it's expected that as time goes on, this will become more general and allow for variously-typed extractions from multiple columns.

Constructor Summary

Constructors

Constructor and Description
RowExtraction(String column, ExtractionFn extractionFn)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static RowExtraction	fromDimensionSpec(DimensionSpec dimensionSpec)
static RowExtraction	fromQueryBuilder(DruidQueryBuilder queryBuilder, int fieldNumber)
String	getColumn()
ExtractionFn	getExtractionFn()
int	hashCode()
boolean	isFilterable(RowSignature rowSignature) Check if this extraction can be used to build a filter on a Druid dataSource.
static RowExtraction	of(String column, ExtractionFn extractionFn)
DimensionSpec	toDimensionSpec(RowSignature rowSignature, String outputName, ValueType outputType)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RowExtraction

public RowExtraction(String column,
                     ExtractionFn extractionFn)

Method Detail

of

public static RowExtraction of(String column,
                               ExtractionFn extractionFn)

fromDimensionSpec

public static RowExtraction fromDimensionSpec(DimensionSpec dimensionSpec)

fromQueryBuilder

public static RowExtraction fromQueryBuilder(DruidQueryBuilder queryBuilder,
                                             int fieldNumber)

getColumn

public String getColumn()

getExtractionFn

public ExtractionFn getExtractionFn()

isFilterable

public boolean isFilterable(RowSignature rowSignature)

Check if this extraction can be used to build a filter on a Druid dataSource. This method exists because we can't filter on floats (yet) and things like DruidFilterRule need to check for that.

Parameters:

rowSignature - row signature of the dataSource

Returns:

whether or not this extraction is filterable

toDimensionSpec

public DimensionSpec toDimensionSpec(RowSignature rowSignature,
                                     String outputName,
                                     ValueType outputType)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object