Package | Description |
---|---|
org.apache.lens.cube.parse | |
org.apache.lens.cube.parse.join | |
org.apache.lens.driver.cube |
Modifier and Type | Method and Description |
---|---|
CubeQueryContext |
CubeQueryRewriter.rewrite(org.apache.hadoop.hive.ql.parse.ASTNode astnode) |
CubeQueryContext |
CubeQueryRewriter.rewrite(String command) |
Modifier and Type | Method and Description |
---|---|
void |
CandidateFact.copyASTs(CubeQueryContext cubeql) |
Set<String> |
CandidateFact.getTimePartCols(CubeQueryContext query) |
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
|
boolean |
CandidateFact.isExpressionAnswerable(org.apache.hadoop.hive.ql.parse.ASTNode node,
CubeQueryContext context) |
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 |
CandidateFact.updateASTs(CubeQueryContext cubeql)
Update the ASTs to include only the fields queried from this fact, in all the expressions
|
abstract boolean |
ValidationRule.validate(CubeQueryContext ctx) |
boolean |
CheckTableNames.validate(CubeQueryContext ctx) |
boolean |
CheckColumnMapping.validate(CubeQueryContext ctx) |
void |
FieldValidator.validateFields(CubeQueryContext cubeql) |
Constructor and Description |
---|
UnionHQLContext(CubeQueryContext query,
CandidateFact fact) |
UnionHQLContext(CubeQueryContext query,
CandidateFact fact,
List<HQLContextInterface> hqlContexts) |
Modifier and Type | Method and Description |
---|---|
String |
AutoJoinContext.getFromString(String fromTable,
CandidateFact fact,
Set<Dimension> qdims,
Map<Dimension,CandidateDim> dimsToQuery,
CubeQueryContext cubeql) |
String |
AutoJoinContext.getMergedJoinClause(CubeQueryContext cubeql,
JoinClause joinClause,
Map<Dimension,CandidateDim> dimsToQuery) |
Set<Dimension> |
AutoJoinContext.pickOptionalTables(CandidateFact fact,
Set<Dimension> qdims,
CubeQueryContext cubeql) |
Constructor and Description |
---|
JoinClause(CubeQueryContext cubeql,
Map<Aliased<Dimension>,List<TableRelationship>> chain,
Set<Dimension> dimsInPath) |
Constructor and Description |
---|
RewriterPlan(Collection<CubeQueryContext> cubeQueries) |
Copyright © 2014–2016 Apache Software Foundation. All rights reserved.