org.apache.lens.cube.metadata

Class JAXBUtils

java.lang.Object

org.apache.lens.cube.metadata.JAXBUtils

public final class JAXBUtils
extends Object

Utilities for converting to and from JAXB types to hive.ql.metadata.cube types

Method Summary

Modifier and Type	Method and Description
static XColumn	columnFromFieldSchema(org.apache.hadoop.hive.metastore.api.FieldSchema fs)
static List<XColumn>	columnsFromFieldSchemaList(List<org.apache.hadoop.hive.metastore.api.FieldSchema> fslist)
static Map<String,String>	columnStartAndEndTimeFromXColumns(XColumns columns)
static CubeDimensionTable	cubeDimTableFromDimTable(XDimensionTable dimensionTable)
static CubeFactTable	cubeFactFromFactTable(XFactTable fact)
static CubeVirtualFactTable	cubeVirtualFactFromFactTable(XVirtualFactTable fact, FactTable sourceFactTable)
static Dimension	dimensionFromXDimension(XDimension dimension)
static List<? extends XTableReference>	dimRefListFromTabRefList(List<TableReference> tabRefs)
static XDimensionTable	dimTableFromCubeDimTable(CubeDimensionTable cubeDimTable)
static Map<String,UpdatePeriod>	dumpPeriodsFromStorageTables(XStorageTables storageTables)
static XFactTable	factTableFromCubeFactTable(FactTable cFact)
static org.apache.hadoop.hive.metastore.api.FieldSchema	fieldSchemaFromColumn(XColumn c)
static ArrayList<org.apache.hadoop.hive.metastore.api.FieldSchema>	fieldSchemaListFromColumns(XColumns columns)
static Date	getDateFromXML(XMLGregorianCalendar cal) Get Date from XMLGregorianCalendar Useful for converting from XML spec to java code.
static Map<String,Set<UpdatePeriod>>	getFactUpdatePeriodsFromStorageTables(XStorageTables storageTables)
static Map<String,String>	getFullPartSpecAsMap(XPartition partition)
static XStorageTableDesc	getStorageTableDescFromHiveTable(org.apache.hadoop.hive.ql.metadata.Table tbl)
static XJoinChain	getXJoinChainFromJoinChain(JoinChain jc) Create XJoinChain from cube join chain
static XMLGregorianCalendar	getXMLGregorianCalendar(Date d) Get XMLGregorianCalendar from Date.
static XProperties	getXProperties(List<XProperty> prop)
static XProperties	getXpropertiesFromSegment(Segment cseg)
static XStorageTableElement	getXStorageTableFromHiveTable(org.apache.hadoop.hive.ql.metadata.Table tbl)
static CubeInterface	hiveCubeFromXCube(XCube cube, Cube parent) Create a hive ql cube object from corresponding JAXB object
static CubeDimAttribute	hiveDimAttrFromXDimAttr(XDimAttribute xd) Create a hive ql CubeDimension from JAXB counterpart
static ExprColumn	hiveExprColumnFromXExprColumn(XExprColumn xe)
static CubeMeasure	hiveMeasureFromXMeasure(XMeasure xm) Create hive ql CubeMeasure from JAXB counterpart
static JoinChain	joinChainFromXJoinChain(XJoinChain xj) Create cube's JoinChain from JAXB counterpart
static Map<String,String>	mapFromXProperties(XProperties xProperties) Convert JAXB properties to Map<String, String>
static XNativeTable	nativeTableFromMetaTable(org.apache.hadoop.hive.ql.metadata.Table table)
static Map<String,String>	nonTimePartSpecfromXNonTimePartSpec(XPartSpec xnonTimePartSpec)
static Segmentation	segmentationFromXSegmentation(XSegmentation seg)
static Set<Segment>	segmentsFromXSegments(XSegments segs)
static Storage	storageFromXStorage(XStorage xs)
static StoragePartitionDesc	storagePartSpecFromXPartition(XPartition xpart)
static List<StoragePartitionDesc>	storagePartSpecListFromXPartitionList(XPartitionList xpartList)
static StorageTableDesc	storageTableDescFromXStorageTableDesc(XStorageTableDesc xtableDesc)
static StorageTableDesc	storageTableDescFromXStorageTableElement(XStorageTableElement storageTableElement)
static Map<String,Map<UpdatePeriod,String>>	storageTablePrefixMapOfStorage(XStorageTables storageTables)
static Map<String,StorageTableDesc>	tableDescPrefixMapFromXStorageTables(XStorageTables storageTables)
static Map<String,Date>	timePartSpecfromXTimePartSpec(XTimePartSpec xtimePartSpec)
static void	updatePartitionFromXPartition(org.apache.hadoop.hive.ql.metadata.Partition partition, XPartition xp)
static XVirtualFactTable	virtualFactTableFromVirtualCubeFactTable(CubeVirtualFactTable vFact)
static XCube	xCubeFromHiveCube(CubeInterface c) Get XCube from hive.ql.metadata.Cube
static XDimAttribute	xDimAttrFromHiveDimAttr(CubeDimAttribute cd, AbstractBaseTable baseTable) Create XDimAttribute from CubeDimAttribute
static XDimension	xdimensionFromDimension(Dimension dimension)
static XExprColumn	xExprColumnFromHiveExprColumn(ExprColumn ec) Create XExprColumn from hive ExprColum
static XJoinPath	xJoinPathFromJoinPath(JoinChain.Path path)
static XMeasure	xMeasureFromHiveMeasure(CubeMeasure cm) Create XMeasure from hive ql cube measure
static XPartition	xpartitionFromPartition(String cubeTableName, org.apache.hadoop.hive.ql.metadata.Partition p, List<String> timePartCols)
static XPartitionList	xpartitionListFromPartitionList(String cubeTableName, List<org.apache.hadoop.hive.ql.metadata.Partition> partitions, List<String> timePartCols)
static List<XProperty>	xPropertiesFromMap(Map<String,String> map) Convert string map to XProperties
static XSegmentation	xsegmentationFromSegmentation(Segmentation cSeg)
static Set<XSegment>	xSegmentsFromSegments(Set<Segment> segs)
static XStorage	xstorageFromStorage(Storage storage)
static List<XTableReference>	xTabReferencesFromHiveTabReferences(List<TableReference> hiveRefs)

Methods inherited from class java.lang.Object

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

Method Detail

hiveCubeFromXCube

public static CubeInterface hiveCubeFromXCube(XCube cube,
                                              Cube parent)
                                       throws LensException

Create a hive ql cube object from corresponding JAXB object

Parameters:

cube - JAXB Cube

Returns:

Cube

Throws:

LensException

xCubeFromHiveCube

public static XCube xCubeFromHiveCube(CubeInterface c)

Get XCube from hive.ql.metadata.Cube

Parameters:

c -

Returns:

XCube

hiveDimAttrFromXDimAttr

public static CubeDimAttribute hiveDimAttrFromXDimAttr(XDimAttribute xd)
                                                throws LensException

Create a hive ql CubeDimension from JAXB counterpart

Parameters:

xd -

Returns:

CubeDimAttribute

Throws:

LensException

getXMLGregorianCalendar

public static XMLGregorianCalendar getXMLGregorianCalendar(Date d)

Get XMLGregorianCalendar from Date. Useful for converting from java code to XML spec.

Parameters:

d - Date value

Returns:

XML value

getDateFromXML

public static Date getDateFromXML(XMLGregorianCalendar cal)

Get Date from XMLGregorianCalendar Useful for converting from XML spec to java code.

Parameters:

cal - XML value

Returns:

Date value

xMeasureFromHiveMeasure

public static XMeasure xMeasureFromHiveMeasure(CubeMeasure cm)

Create XMeasure from hive ql cube measure

getXProperties

public static XProperties getXProperties(List<XProperty> prop)

xExprColumnFromHiveExprColumn

public static XExprColumn xExprColumnFromHiveExprColumn(ExprColumn ec)

Create XExprColumn from hive ExprColum

xDimAttrFromHiveDimAttr

public static XDimAttribute xDimAttrFromHiveDimAttr(CubeDimAttribute cd,
                                                    AbstractBaseTable baseTable)

Create XDimAttribute from CubeDimAttribute

getXJoinChainFromJoinChain

public static XJoinChain getXJoinChainFromJoinChain(JoinChain jc)

Create XJoinChain from cube join chain

xJoinPathFromJoinPath

public static XJoinPath xJoinPathFromJoinPath(JoinChain.Path path)

xTabReferencesFromHiveTabReferences

public static List<XTableReference> xTabReferencesFromHiveTabReferences(List<TableReference> hiveRefs)

hiveMeasureFromXMeasure

public static CubeMeasure hiveMeasureFromXMeasure(XMeasure xm)

Create hive ql CubeMeasure from JAXB counterpart

Parameters:

xm -

Returns:

CubeMeasure

joinChainFromXJoinChain

public static JoinChain joinChainFromXJoinChain(XJoinChain xj)

Create cube's JoinChain from JAXB counterpart

Parameters:

xj -

Returns:

JoinChain

hiveExprColumnFromXExprColumn

public static ExprColumn hiveExprColumnFromXExprColumn(XExprColumn xe)
                                                throws LensException

Throws:

LensException

mapFromXProperties

public static Map<String,String> mapFromXProperties(XProperties xProperties)

Convert JAXB properties to Map<String, String>

Parameters:

xProperties -

Returns:

Map

xPropertiesFromMap

public static List<XProperty> xPropertiesFromMap(Map<String,String> map)

Convert string map to XProperties

xSegmentsFromSegments

public static Set<XSegment> xSegmentsFromSegments(Set<Segment> segs)

getXpropertiesFromSegment

public static XProperties getXpropertiesFromSegment(Segment cseg)

fieldSchemaFromColumn

public static org.apache.hadoop.hive.metastore.api.FieldSchema fieldSchemaFromColumn(XColumn c)

columnFromFieldSchema

public static XColumn columnFromFieldSchema(org.apache.hadoop.hive.metastore.api.FieldSchema fs)

fieldSchemaListFromColumns

public static ArrayList<org.apache.hadoop.hive.metastore.api.FieldSchema> fieldSchemaListFromColumns(XColumns columns)

columnStartAndEndTimeFromXColumns

public static Map<String,String> columnStartAndEndTimeFromXColumns(XColumns columns)

columnsFromFieldSchemaList

public static List<XColumn> columnsFromFieldSchemaList(List<org.apache.hadoop.hive.metastore.api.FieldSchema> fslist)

getFactUpdatePeriodsFromStorageTables

public static Map<String,Set<UpdatePeriod>> getFactUpdatePeriodsFromStorageTables(XStorageTables storageTables)

dumpPeriodsFromStorageTables

public static Map<String,UpdatePeriod> dumpPeriodsFromStorageTables(XStorageTables storageTables)

storageFromXStorage

public static Storage storageFromXStorage(XStorage xs)

xstorageFromStorage

public static XStorage xstorageFromStorage(Storage storage)

dimTableFromCubeDimTable

public static XDimensionTable dimTableFromCubeDimTable(CubeDimensionTable cubeDimTable)

dimRefListFromTabRefList

public static List<? extends XTableReference> dimRefListFromTabRefList(List<TableReference> tabRefs)

cubeDimTableFromDimTable

public static CubeDimensionTable cubeDimTableFromDimTable(XDimensionTable dimensionTable)
                                                   throws LensException

Throws:

LensException

cubeFactFromFactTable

public static CubeFactTable cubeFactFromFactTable(XFactTable fact)
                                           throws LensException

Throws:

LensException

cubeVirtualFactFromFactTable

public static CubeVirtualFactTable cubeVirtualFactFromFactTable(XVirtualFactTable fact,
                                                                FactTable sourceFactTable)
                                                         throws LensException

Throws:

LensException

segmentationFromXSegmentation

public static Segmentation segmentationFromXSegmentation(XSegmentation seg)
                                                  throws LensException

Throws:

LensException

factTableFromCubeFactTable

public static XFactTable factTableFromCubeFactTable(FactTable cFact)

virtualFactTableFromVirtualCubeFactTable

public static XVirtualFactTable virtualFactTableFromVirtualCubeFactTable(CubeVirtualFactTable vFact)

xsegmentationFromSegmentation

public static XSegmentation xsegmentationFromSegmentation(Segmentation cSeg)

storageTableDescFromXStorageTableDesc

public static StorageTableDesc storageTableDescFromXStorageTableDesc(XStorageTableDesc xtableDesc)

storageTableDescFromXStorageTableElement

public static StorageTableDesc storageTableDescFromXStorageTableElement(XStorageTableElement storageTableElement)

getXStorageTableFromHiveTable

public static XStorageTableElement getXStorageTableFromHiveTable(org.apache.hadoop.hive.ql.metadata.Table tbl)

getStorageTableDescFromHiveTable

public static XStorageTableDesc getStorageTableDescFromHiveTable(org.apache.hadoop.hive.ql.metadata.Table tbl)

tableDescPrefixMapFromXStorageTables

public static Map<String,StorageTableDesc> tableDescPrefixMapFromXStorageTables(XStorageTables storageTables)

storageTablePrefixMapOfStorage

public static Map<String,Map<UpdatePeriod,String>> storageTablePrefixMapOfStorage(XStorageTables storageTables)

segmentsFromXSegments

public static Set<Segment> segmentsFromXSegments(XSegments segs)

timePartSpecfromXTimePartSpec

public static Map<String,Date> timePartSpecfromXTimePartSpec(XTimePartSpec xtimePartSpec)

nonTimePartSpecfromXNonTimePartSpec

public static Map<String,String> nonTimePartSpecfromXNonTimePartSpec(XPartSpec xnonTimePartSpec)

xpartitionListFromPartitionList

public static XPartitionList xpartitionListFromPartitionList(String cubeTableName,
                                                             List<org.apache.hadoop.hive.ql.metadata.Partition> partitions,
                                                             List<String> timePartCols)
                                                      throws org.apache.hadoop.hive.ql.metadata.HiveException

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

xpartitionFromPartition

public static XPartition xpartitionFromPartition(String cubeTableName,
                                                 org.apache.hadoop.hive.ql.metadata.Partition p,
                                                 List<String> timePartCols)
                                          throws org.apache.hadoop.hive.ql.metadata.HiveException

Throws:

org.apache.hadoop.hive.ql.metadata.HiveException

updatePartitionFromXPartition

public static void updatePartitionFromXPartition(org.apache.hadoop.hive.ql.metadata.Partition partition,
                                                 XPartition xp)
                                          throws ClassNotFoundException

Throws:

ClassNotFoundException

storagePartSpecFromXPartition

public static StoragePartitionDesc storagePartSpecFromXPartition(XPartition xpart)

storagePartSpecListFromXPartitionList

public static List<StoragePartitionDesc> storagePartSpecListFromXPartitionList(XPartitionList xpartList)

dimensionFromXDimension

public static Dimension dimensionFromXDimension(XDimension dimension)
                                         throws LensException

Throws:

LensException

xdimensionFromDimension

public static XDimension xdimensionFromDimension(Dimension dimension)

nativeTableFromMetaTable

public static XNativeTable nativeTableFromMetaTable(org.apache.hadoop.hive.ql.metadata.Table table)

getFullPartSpecAsMap

public static Map<String,String> getFullPartSpecAsMap(XPartition partition)