org.apache.hadoop.hive.ql.parse

Class EximUtil

java.lang.Object

org.apache.hadoop.hive.ql.parse.EximUtil

public class EximUtil
extends Object

EximUtil. Utility methods for the export/import semantic analyzers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EximUtil.ReadMetaData Utility class to help return complex value from readMetaData function

Field Summary

Fields

Modifier and Type	Field and Description
static String	METADATA_FORMAT_FORWARD_COMPATIBLE_VERSION
static String	METADATA_FORMAT_VERSION

Method Summary

Methods

Modifier and Type	Method and Description
static void	createExportDump(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path metadataPath, Table tableHandle, Iterable<Partition> partitions, ReplicationSpec replicationSpec)
static void	doCheckCompatibility(String currVersion, String version, String fcVersion)
static Map<String,String>	makePartSpec(List<FieldSchema> partCols, List<String> partVals) Return the partition specification from the specified keys and values
static EximUtil.ReadMetaData	readMetaData(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path metadataPath)
static String	relativeToAbsolutePath(HiveConf conf, String location)
static boolean	schemaCompare(List<FieldSchema> newSchema, List<FieldSchema> oldSchema) Compares the schemas - names, types and order, but ignoring comments

Methods inherited from class java.lang.Object

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

Field Detail

METADATA_FORMAT_VERSION

public static final String METADATA_FORMAT_VERSION

See Also:

Constant Field Values

METADATA_FORMAT_FORWARD_COMPATIBLE_VERSION

public static final String METADATA_FORMAT_FORWARD_COMPATIBLE_VERSION

Method Detail

relativeToAbsolutePath

public static String relativeToAbsolutePath(HiveConf conf,
                            String location)
                                     throws SemanticException

Throws:

SemanticException

createExportDump

public static void createExportDump(org.apache.hadoop.fs.FileSystem fs,
                    org.apache.hadoop.fs.Path metadataPath,
                    Table tableHandle,
                    Iterable<Partition> partitions,
                    ReplicationSpec replicationSpec)
                             throws SemanticException,
                                    IOException

Throws:

SemanticException

IOException

readMetaData

public static EximUtil.ReadMetaData readMetaData(org.apache.hadoop.fs.FileSystem fs,
                                 org.apache.hadoop.fs.Path metadataPath)
                                          throws IOException,
                                                 SemanticException

Throws:

IOException

SemanticException

doCheckCompatibility

public static void doCheckCompatibility(String currVersion,
                        String version,
                        String fcVersion)
                                 throws SemanticException

Throws:

SemanticException

makePartSpec

public static Map<String,String> makePartSpec(List<FieldSchema> partCols,
                              List<String> partVals)

Return the partition specification from the specified keys and values

Parameters:

partCols - the names of the partition keys

partVals - the values of the partition keys

Returns:

the partition specification as a map

schemaCompare

public static boolean schemaCompare(List<FieldSchema> newSchema,
                    List<FieldSchema> oldSchema)

Compares the schemas - names, types and order, but ignoring comments

Parameters:

newSchema - the new schema

oldSchema - the old schema

Returns:

a boolean indicating match