public class EximUtil extends Object
Modifier and Type | Class and Description |
---|---|
static class |
EximUtil.SemanticAnalyzerWrapperContext
Wrapper class for common BaseSemanticAnalyzer non-static members
into static generic methods without having the fn signatures
becoming overwhelming, with passing each of these into every function.
|
Modifier and Type | Field and Description |
---|---|
static String |
DATA_PATH_NAME |
static String |
FILES_NAME |
static String |
METADATA_FORMAT_FORWARD_COMPATIBLE_VERSION |
static String |
METADATA_FORMAT_VERSION |
static String |
METADATA_NAME |
Modifier and Type | Method and Description |
---|---|
static void |
createDbExportDump(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path metadataPath,
Database dbObj,
ReplicationSpec replicationSpec) |
static void |
createExportDump(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path metadataPath,
Table tableHandle,
Iterable<Partition> partitions,
ReplicationSpec replicationSpec,
HiveConf hiveConf) |
static void |
doCheckCompatibility(String currVersion,
String version,
String fcVersion) |
static org.apache.hadoop.fs.PathFilter |
getDirectoryFilter(org.apache.hadoop.fs.FileSystem fs) |
static URI |
getValidatedURI(HiveConf conf,
String dcPath)
Initialize the URI where the exported data collection is
to created for export, or is present for import
|
static Map<String,String> |
makePartSpec(List<FieldSchema> partCols,
List<String> partVals)
Return the partition specification from the specified keys and values
|
static String |
readAsString(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path fromMetadataPath) |
static MetaData |
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
|
public static final String METADATA_NAME
public static final String FILES_NAME
public static final String DATA_PATH_NAME
public static final String METADATA_FORMAT_VERSION
public static final String METADATA_FORMAT_FORWARD_COMPATIBLE_VERSION
public static URI getValidatedURI(HiveConf conf, String dcPath) throws SemanticException
SemanticException
public static String relativeToAbsolutePath(HiveConf conf, String location) throws SemanticException
SemanticException
public static void createDbExportDump(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path metadataPath, Database dbObj, ReplicationSpec replicationSpec) throws IOException, SemanticException
IOException
SemanticException
public static void createExportDump(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path metadataPath, Table tableHandle, Iterable<Partition> partitions, ReplicationSpec replicationSpec, HiveConf hiveConf) throws SemanticException, IOException
SemanticException
IOException
public static MetaData readMetaData(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path metadataPath) throws IOException, SemanticException
IOException
SemanticException
public static String readAsString(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path fromMetadataPath) throws IOException
IOException
public static void doCheckCompatibility(String currVersion, String version, String fcVersion) throws SemanticException
SemanticException
public static Map<String,String> makePartSpec(List<FieldSchema> partCols, List<String> partVals)
partCols
- the names of the partition keyspartVals
- the values of the partition keyspublic static boolean schemaCompare(List<FieldSchema> newSchema, List<FieldSchema> oldSchema)
newSchema
- the new schemaoldSchema
- the old schemapublic static org.apache.hadoop.fs.PathFilter getDirectoryFilter(org.apache.hadoop.fs.FileSystem fs)
Copyright © 2022 The Apache Software Foundation. All rights reserved.