This project has retired. For details please refer to its Attic page.

org.apache.lens.cube.parse
Class DenormalizationResolver

java.lang.Object
  org.apache.lens.cube.parse.DenormalizationResolver

public class DenormalizationResolver
extends Object

This class resolves all the reference columns that are queried.

Keeps track of the context that if any candidate needs to use columns through tables referenced and replaces the columns from referenced tables in all the ASTs

Nested Class Summary

static class	DenormalizationResolver.DenormalizationContext
static class	DenormalizationResolver.PickedReference
static class	DenormalizationResolver.ReferencedQueriedColumn

Constructor Summary

DenormalizationResolver(org.apache.hadoop.conf.Configuration conf)

Method Summary

void	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

Methods inherited from class java.lang.Object

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

Constructor Detail

DenormalizationResolver

public DenormalizationResolver(org.apache.hadoop.conf.Configuration conf)

Method Detail

rewriteContext

public void rewriteContext(CubeQueryContext cubeql)
                    throws org.apache.hadoop.hive.ql.parse.SemanticException

Find all de-normalized columns, if these columns are not directly available in candidate tables, query will be replaced with the corresponding table reference

Parameters:

cubeql - CubeQueryContext

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException