Package org.apache.druid.segment.projections

Class ProjectionMatchBuilder

java.lang.Object

org.apache.druid.segment.projections.ProjectionMatchBuilder

public final class ProjectionMatchBuilder
extends Object

State holder used by Projections.matchAggregateProjection(org.apache.druid.segment.AggregateProjectionMetadata.Schema, org.apache.druid.segment.CursorBuildSpec, org.joda.time.Interval, org.apache.druid.segment.projections.Projections.PhysicalColumnChecker) for building a ProjectionMatch. Tracks which all kinds of stuff to map a projection to the contents of a query CursorBuildSpec, accumulating details about how to transform into a new CursorBuildSpec that will run against the projection.

Constructor Summary

Constructors

Constructor	Description
ProjectionMatchBuilder()

Method Summary

Modifier and Type	Method	Description
ProjectionMatchBuilder	addPreAggregatedAggregator(AggregatorFactory aggregator)	Add a query AggregatorFactory.substituteCombiningFactory(AggregatorFactory) which can combine the inputs of a selector created by a projection AggregatorFactory
ProjectionMatchBuilder	addReferencedPhysicalColumn(String column)	Add a projection physical column, which will later be added to ProjectionMatch.getCursorBuildSpec() if the projection matches
ProjectionMatchBuilder	addReferenceedVirtualColumn(VirtualColumn virtualColumn)	Add a query virtual column that can use projection physical columns as inputs to the match builder, which will later be added to ProjectionMatch.getCursorBuildSpec() if the projection matches
ProjectionMatch	build(CursorBuildSpec queryCursorBuildSpec)
Map<String,String>	getRemapColumns()
String	getRemapValue(String queryColumn)
Filter	getRewriteFilter()
ProjectionMatchBuilder	remapColumn(String queryColumn, String projectionColumn)	Map a query column name to a projection column name
ProjectionMatchBuilder	rewriteFilter(Filter rewriteFilter)

Methods inherited from class java.lang.Object

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

Constructor Details

ProjectionMatchBuilder

public ProjectionMatchBuilder()

Method Details

remapColumn

public ProjectionMatchBuilder remapColumn(String queryColumn,
 String projectionColumn)

Map a query column name to a projection column name

getRemapValue

@Nullable
public String getRemapValue(String queryColumn)

addReferencedPhysicalColumn

public ProjectionMatchBuilder addReferencedPhysicalColumn(String column)

Add a projection physical column, which will later be added to ProjectionMatch.getCursorBuildSpec() if the projection matches

addReferenceedVirtualColumn

public ProjectionMatchBuilder addReferenceedVirtualColumn(VirtualColumn virtualColumn)

Add a query virtual column that can use projection physical columns as inputs to the match builder, which will later be added to ProjectionMatch.getCursorBuildSpec() if the projection matches

addPreAggregatedAggregator

public ProjectionMatchBuilder addPreAggregatedAggregator(AggregatorFactory aggregator)

Add a query AggregatorFactory.substituteCombiningFactory(AggregatorFactory) which can combine the inputs of a selector created by a projection AggregatorFactory

rewriteFilter

public ProjectionMatchBuilder rewriteFilter(Filter rewriteFilter)

getRewriteFilter

public Filter getRewriteFilter()

getRemapColumns

public Map<String,String> getRemapColumns()

build

public ProjectionMatch build(CursorBuildSpec queryCursorBuildSpec)