Package org.apache.druid.segment.join.filter

Class JoinFilterPreAnalysis

java.lang.Object

org.apache.druid.segment.join.filter.JoinFilterPreAnalysis

public class JoinFilterPreAnalysis
extends Object

A JoinFilterPreAnalysis contains filter push down/rewrite information that does not have per-segment dependencies. This includes: - The query's JoinableClauses list - The original filter that an analysis was performed ons - A list of filter clauses from the original filter's CNF representation that only reference the base table - A list of filter clauses from the original filter's CNF representation that reference RHS join tables - A list of virtual columns that can only be computed post-join - The JoinFilterRewriteConfig that this pre-analysis is associated with.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JoinFilterPreAnalysis.Builder	A Builder class to build JoinFilterPreAnalysis

Method Summary

Modifier and Type	Method	Description
Map<String,List<JoinFilterColumnCorrelationAnalysis>>	getCorrelationsByDirectFilteringColumn()
Map<String,List<JoinFilterColumnCorrelationAnalysis>>	getCorrelationsByFilteringColumn()
Equiconditions	getEquiconditions()
JoinableClauses	getJoinableClauses()
JoinFilterPreAnalysisKey	getKey()
List<Filter>	getNormalizedBaseTableClauses()
List<Filter>	getNormalizedJoinTableClauses()
Filter	getOriginalFilter()
Set<VirtualColumn>	getPostJoinVirtualColumns()
boolean	isEnableFilterPushDown()
boolean	isEnableFilterRewrite()

Methods inherited from class java.lang.Object

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

Method Details

getKey

public JoinFilterPreAnalysisKey getKey()

getJoinableClauses

public JoinableClauses getJoinableClauses()

getOriginalFilter

@Nullable
public Filter getOriginalFilter()

getPostJoinVirtualColumns

public Set<VirtualColumn> getPostJoinVirtualColumns()

getNormalizedBaseTableClauses

public List<Filter> getNormalizedBaseTableClauses()

getNormalizedJoinTableClauses

public List<Filter> getNormalizedJoinTableClauses()

getCorrelationsByFilteringColumn

public Map<String,List<JoinFilterColumnCorrelationAnalysis>> getCorrelationsByFilteringColumn()

getCorrelationsByDirectFilteringColumn

public Map<String,List<JoinFilterColumnCorrelationAnalysis>> getCorrelationsByDirectFilteringColumn()

isEnableFilterPushDown

public boolean isEnableFilterPushDown()

isEnableFilterRewrite

public boolean isEnableFilterRewrite()

getEquiconditions

public Equiconditions getEquiconditions()