org.apache.lens.server.metastore

Class JAXBUtils

java.lang.Object

org.apache.lens.server.metastore.JAXBUtils

public final class JAXBUtils
extends Object

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

Method Summary

Methods

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 CubeDimensionTable	cubeDimTableFromDimTable(XDimensionTable dimensionTable)
static CubeFactTable	cubeFactFromFactTable(XFactTable fact)
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(CubeFactTable 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 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 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,StorageTableDesc>	storageTableMapFromXStorageTables(XStorageTables storageTables)
static Map<String,Date>	timePartSpecfromXTimePartSpec(XTimePartSpec xtimePartSpec)
static void	updatePartitionFromXPartition(org.apache.hadoop.hive.ql.metadata.Partition partition, XPartition xp)
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 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

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

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)

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

factTableFromCubeFactTable

public static XFactTable factTableFromCubeFactTable(CubeFactTable cFact)

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)

storageTableMapFromXStorageTables

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

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)