org.apache.lens.cube.parse

Class StorageUtil

java.lang.Object

org.apache.lens.cube.parse.StorageUtil

public final class StorageUtil
extends Object

Method Summary

Modifier and Type	Method and Description
static TimeRange	getFallbackRange(TimeRange range, String factName, CubeQueryContext cubeql) Get fallback range
static String	getNotLatestClauseForDimensions(String alias, Set<String> timedDimensions, String partCol)
static String	getWhereClause(CandidateDim dim, String alias)
static String	getWhereClause(String clause, String alias)
static String	getWherePartClause(String timeDimName, String tableName, Collection<String> parts)
static String	getWherePartClauseWithIn(String timeDimName, String tableName, List<String> parts)
static boolean	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	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

Methods inherited from class java.lang.Object

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

Method Detail

getWherePartClause

public static String getWherePartClause(String timeDimName,
                                        String tableName,
                                        Collection<String> parts)

getWherePartClauseWithIn

public static String getWherePartClauseWithIn(String timeDimName,
                                              String tableName,
                                              List<String> parts)

getNotLatestClauseForDimensions

public static String getNotLatestClauseForDimensions(String alias,
                                                     Set<String> timedDimensions,
                                                     String partCol)

getWhereClause

public static String getWhereClause(String clause,
                                    String alias)

getWhereClause

public static String getWhereClause(CandidateDim dim,
                                    String alias)

getFallbackRange

public static TimeRange getFallbackRange(TimeRange range,
                                         String factName,
                                         CubeQueryContext cubeql)
                                  throws LensException

Get fallback range

Parameters:

range -

factName -

cubeql -

Returns:

Throws:

LensException

processCubeColForDataCompleteness

public static boolean processCubeColForDataCompleteness(CubeQueryContext cubeql,
                                                        String cubeCol,
                                                        String alias,
                                                        Set<String> measureTag,
                                                        Map<String,String> tagToMeasureOrExprMap)

Checks how much data is completed for a column. See this: DataCompletenessChecker

Parameters:

cubeql -

cubeCol -

alias -

measureTag -

tagToMeasureOrExprMap -

Returns:

processExpressionsForCompleteness

public static void 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

Parameters:

cubeql -

measureTag -

tagToMeasureOrExprMap -