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

Class JoinFilterCorrelations

java.lang.Object

org.apache.druid.segment.join.filter.JoinFilterCorrelations

public class JoinFilterCorrelations
extends Object

A wrapper class for correlation analyses of different filters involved in the query. It contains: - A mapping of RHS filtering columns -> List, used for filter rewrites - A second mapping of RHS filtering columns -> List, used for direct filter rewrites

Method Summary

Modifier and Type	Method	Description
static JoinFilterCorrelations	computeJoinFilterCorrelations(List<Filter> normalizedJoinTableClauses, Equiconditions equiconditions, JoinableClauses joinableClauses, boolean enableRewriteValueColumnFilters, long filterRewriteMaxSize)
Map<String,List<JoinFilterColumnCorrelationAnalysis>>	getCorrelationsByDirectFilteringColumn()
Map<String,List<JoinFilterColumnCorrelationAnalysis>>	getCorrelationsByFilteringColumn()

Methods inherited from class java.lang.Object

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

Method Details

getCorrelationsByFilteringColumn

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

getCorrelationsByDirectFilteringColumn

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

computeJoinFilterCorrelations

public static JoinFilterCorrelations computeJoinFilterCorrelations(List<Filter> normalizedJoinTableClauses,
 Equiconditions equiconditions,
 JoinableClauses joinableClauses,
 boolean enableRewriteValueColumnFilters,
 long filterRewriteMaxSize)