Package | Description |
---|---|
org.apache.lens.cube.error | |
org.apache.lens.cube.parse | |
org.apache.lens.cube.parse.join | |
org.apache.lens.driver.cube |
Constructor and Description |
---|
NoCandidateFactAvailableException(CubeQueryContext cubeql) |
Modifier and Type | Method and Description |
---|---|
CubeQueryContext |
UnionCandidate.getCubeQueryContext() |
CubeQueryContext |
StorageCandidateHQLContext.getCubeQueryContext() |
CubeQueryContext |
StorageCandidate.getCubeQueryContext() |
CubeQueryContext |
SegmentationCandidate.getCubeQueryContext() |
CubeQueryContext |
MultiCandidateQueryWriterContext.getCubeQueryContext() |
CubeQueryContext |
JoinCandidate.getCubeQueryContext() |
CubeQueryContext |
DimHQLContext.getCubeQueryContext() |
CubeQueryContext |
Candidate.getCubeQueryContext()
A candidate always works along with its cube query context.
|
CubeQueryContext |
CubeQueryRewriter.rewrite(org.apache.hadoop.hive.ql.parse.ASTNode astnode) |
CubeQueryContext |
CubeQueryRewriter.rewrite(String command) |
Modifier and Type | Method and Description |
---|---|
static TimeRange |
StorageUtil.getFallbackRange(TimeRange range,
String factName,
CubeQueryContext cubeql)
Get fallback range
|
static String |
TimeRangeUtils.getTimeRangePartitionFilter(FactPartition partition,
CubeQueryContext cubeQueryContext,
String tableName) |
String |
TimeRangeWriter.getTimeRangeWhereClause(CubeQueryContext cubeQueryContext,
String tableName,
Set<FactPartition> parts) |
String |
ORTimeRangeWriter.getTimeRangeWhereClause(CubeQueryContext cubeQueryContext,
String tableName,
Set<FactPartition> rangeParts) |
String |
BetweenTimeRangeWriter.getTimeRangeWhereClause(CubeQueryContext cubeQueryContext,
String tableName,
Set<FactPartition> rangeParts) |
String |
AbridgedTimeRangeWriter.getTimeRangeWhereClause(CubeQueryContext cubeQueryContext,
String tableName,
Set<FactPartition> parts)
Return IN clause for the partitions selected in the cube query
|
static boolean |
StorageUtil.processCubeColForDataCompleteness(CubeQueryContext cubeql,
String cubeCol,
String alias,
Set<String> measureTag,
Map<String,String> tagToMeasureOrExprMap)
Checks how much data is completed for a column.
|
static void |
StorageUtil.processExpressionsForCompleteness(CubeQueryContext cubeql,
Set<String> measureTag,
Map<String,String> tagToMeasureOrExprMap)
This method extracts all the columns used in expressions (used in query) and evaluates each
column separately for completeness
|
void |
SegmentationInnerRewriter.rewriteContext(CubeQueryContext cubeql) |
void |
LightestFactResolver.rewriteContext(CubeQueryContext cubeql) |
void |
FieldValidator.rewriteContext(CubeQueryContext cubeql) |
void |
DenormalizationResolver.rewriteContext(CubeQueryContext cubeql)
Find all de-normalized columns, if these columns are not directly available in candidate tables, query will be
replaced with the corresponding table reference
|
void |
ColumnLifetimeChecker.rewriteContext(CubeQueryContext cubeql) |
void |
CandidateExploder.rewriteContext(CubeQueryContext cubeql)
Replacing all candidates with their exploded versions in cubeql.getCandidates()
|
void |
CandidateCoveringSetsResolver.rewriteContext(CubeQueryContext cubeql) |
StorageCandidateHQLContext |
StorageCandidate.toQueryWriterContext(Map<Dimension,CandidateDim> dimsToQuery,
CubeQueryContext rootCubeQueryContext) |
default QueryWriterContext |
Candidate.toQueryWriterContext(Map<Dimension,CandidateDim> dimsToQuery,
CubeQueryContext rootCubeQueryContext)
Get query writer context from the candidate.
|
abstract boolean |
ValidationRule.validate(CubeQueryContext ctx) |
boolean |
CheckTableNames.validate(CubeQueryContext ctx) |
boolean |
CheckColumnMapping.validate(CubeQueryContext ctx) |
void |
FieldValidator.validateFields(CubeQueryContext cubeql) |
Constructor and Description |
---|
JoinCandidate(Candidate childCandidate1,
Candidate childCandidate2,
CubeQueryContext cubeql) |
MultiCandidateQueryWriterContext(List<QueryWriterContext> children,
CubeQueryContext cubeQueryContext) |
StorageCandidate(CubeInterface cube,
FactTable fact,
String storageName,
CubeQueryContext cubeQueryContext) |
Modifier and Type | Method and Description |
---|---|
String |
AutoJoinContext.getFromString(String fromTable,
DimHQLContext sc,
Map<Dimension,CandidateDim> dimsToQuery,
CubeQueryContext cubeql) |
String |
AutoJoinContext.getMergedJoinClause(CubeQueryContext cubeql,
DimHQLContext sc,
JoinClause joinClause,
Map<Dimension,CandidateDim> dimsToQuery) |
Set<Dimension> |
AutoJoinContext.pickOptionalTables(DimHQLContext sc,
Set<Dimension> qdims,
CubeQueryContext cubeql) |
Constructor and Description |
---|
BridgeTableJoinContext(CubeQueryContext cubeql,
DimHQLContext sc,
String bridgeTableFieldAggr,
String arrayFilter,
boolean doFlatteningEarly) |
JoinClause(CubeQueryContext cubeql,
Map<Aliased<Dimension>,List<TableRelationship>> chain,
Set<Dimension> dimsInPath) |
Constructor and Description |
---|
RewriterPlan(Collection<CubeQueryContext> cubeQueries) |
Copyright © 2014–2018 Apache Software Foundation. All rights reserved.