Package org.apache.druid.query.planning

Class PreJoinableClause

java.lang.Object

org.apache.druid.query.planning.PreJoinableClause

public class PreJoinableClause
extends Object

Like JoinableClause, but contains a DataSource instead of a Joinable. This is useful because when analyzing joins, we don't want to actually create Joinables, since that can be an expensive operation.

Constructor Summary

Constructors

Constructor	Description
PreJoinableClause(JoinDataSource joinDataSource)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
JoinConditionAnalysis	getCondition()
DataSource	getDataSource()
JoinAlgorithm	getJoinAlgorithm()
JoinType	getJoinType()
String	getPrefix()
int	hashCode()
JoinDataSource	makeUpdatedJoinDataSource(DataSource newSource, DimFilter joinBaseFilter, JoinableFactoryWrapper joinableFactoryWrapper)
DataSource	maybeUnwrapRestrictedDataSource()	If the data source is a RestrictedDataSource with a NoRestrictionPolicy, unwraps it to a table and return.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

PreJoinableClause

public PreJoinableClause(JoinDataSource joinDataSource)

Method Details

getPrefix

public String getPrefix()

getDataSource

public DataSource getDataSource()

maybeUnwrapRestrictedDataSource

public DataSource maybeUnwrapRestrictedDataSource()

If the data source is a RestrictedDataSource with a NoRestrictionPolicy, unwraps it to a table and return.

This is a temporary workaround to allow the planner to work with RestrictedDataSource as the right-side join.

getJoinType

public JoinType getJoinType()

getCondition

public JoinConditionAnalysis getCondition()

getJoinAlgorithm

@Nullable
public JoinAlgorithm getJoinAlgorithm()

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

makeUpdatedJoinDataSource

public JoinDataSource makeUpdatedJoinDataSource(DataSource newSource,
 DimFilter joinBaseFilter,
 JoinableFactoryWrapper joinableFactoryWrapper)