org.apache.hadoop.hive.ql.plan

Class ExportWork

java.lang.Object

org.apache.hadoop.hive.ql.plan.ExportWork

All Implemented Interfaces:

Serializable

public class ExportWork
extends Object
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExportWork.MmContext

Constructor Summary

Constructors

Constructor and Description
ExportWork(String exportRootDirName, BaseSemanticAnalyzer.TableSpec tableSpec, ReplicationSpec replicationSpec, String astRepresentationForErrorMsg, String acidFqTableName, ExportWork.MmContext mmContext)

Method Summary

Modifier and Type	Method and Description
void	acidPostProcess(Hive db) For exporting Acid table, change the "pointer" to the temp table.
String	getAstRepresentationForErrorMsg()
String	getExportRootDir()
ExportWork.MmContext	getMmContext()
ReplicationSpec	getReplicationSpec()
BaseSemanticAnalyzer.TableSpec	getTableSpec()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExportWork

public ExportWork(String exportRootDirName,
                  BaseSemanticAnalyzer.TableSpec tableSpec,
                  ReplicationSpec replicationSpec,
                  String astRepresentationForErrorMsg,
                  String acidFqTableName,
                  ExportWork.MmContext mmContext)

Parameters:

acidFqTableName - if exporting Acid table, this is temp table - null otherwise

Method Detail

getExportRootDir

public String getExportRootDir()

getTableSpec

public BaseSemanticAnalyzer.TableSpec getTableSpec()

getReplicationSpec

public ReplicationSpec getReplicationSpec()

getAstRepresentationForErrorMsg

public String getAstRepresentationForErrorMsg()

getMmContext

public ExportWork.MmContext getMmContext()

acidPostProcess

public void acidPostProcess(Hive db)
                     throws HiveException

For exporting Acid table, change the "pointer" to the temp table. This has to be done after the temp table is populated and all necessary Partition objects exist in the metastore. See UpdateDeleteSemanticAnalyzer.isAcidExport(ASTNode) for more info.

Throws:

HiveException