Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.repl.bootstrap.events | |
org.apache.hadoop.hive.ql.exec.repl.bootstrap.events.filesystem | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.parse.repl.dump | |
org.apache.hadoop.hive.ql.parse.repl.dump.events | |
org.apache.hadoop.hive.ql.parse.repl.dump.io | |
org.apache.hadoop.hive.ql.parse.repl.load | |
org.apache.hadoop.hive.ql.plan |
Modifier and Type | Method and Description |
---|---|
static Task<?> |
ReplCopyTask.getLoadCopyTask(ReplicationSpec replicationSpec,
org.apache.hadoop.fs.Path srcPath,
org.apache.hadoop.fs.Path dstPath,
HiveConf conf) |
Modifier and Type | Method and Description |
---|---|
ReplicationSpec |
TableEvent.replicationSpec() |
Modifier and Type | Method and Description |
---|---|
ReplicationSpec |
FSTableEvent.replicationSpec() |
ReplicationSpec |
FSPartitionEvent.replicationSpec() |
Modifier and Type | Method and Description |
---|---|
static void |
ImportSemanticAnalyzer.checkTargetLocationEmpty(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path targetPath,
ReplicationSpec replicationSpec,
org.slf4j.Logger logger) |
static void |
EximUtil.createDbExportDump(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path metadataPath,
Database dbObj,
ReplicationSpec replicationSpec) |
static void |
EximUtil.createExportDump(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path metadataPath,
Table tableHandle,
Iterable<Partition> partitions,
ReplicationSpec replicationSpec,
HiveConf hiveConf) |
Modifier and Type | Field and Description |
---|---|
ReplicationSpec |
HiveWrapper.Tuple.replicationSpec |
Modifier and Type | Method and Description |
---|---|
static boolean |
Utils.shouldReplicate(NotificationEvent tableForEvent,
ReplicationSpec replicationSpec,
Hive db,
HiveConf hiveConf) |
static Boolean |
Utils.shouldReplicate(ReplicationSpec replicationSpec,
Table tableHandle,
HiveConf hiveConf)
validates if a table can be exported, similar to EximUtil.shouldExport with few replication
specific checks.
|
Constructor and Description |
---|
TableExport(TableExport.Paths paths,
BaseSemanticAnalyzer.TableSpec tableSpec,
ReplicationSpec replicationSpec,
Hive db,
String distCpDoAsUser,
HiveConf conf,
ExportWork.MmContext mmCtx) |
Constructor and Description |
---|
Context(org.apache.hadoop.fs.Path eventRoot,
org.apache.hadoop.fs.Path cmRoot,
Hive db,
HiveConf hiveConf,
ReplicationSpec replicationSpec) |
Modifier and Type | Method and Description |
---|---|
void |
FileOperations.export(ReplicationSpec forReplicationSpec) |
void |
ConstraintsSerializer.writeTo(JsonWriter writer,
ReplicationSpec additionalPropertiesProvider) |
void |
JsonWriter.Serializer.writeTo(JsonWriter writer,
ReplicationSpec additionalPropertiesProvider) |
void |
ReplicationSpecSerializer.writeTo(JsonWriter writer,
ReplicationSpec additionalPropertiesProvider) |
void |
DBSerializer.writeTo(JsonWriter writer,
ReplicationSpec additionalPropertiesProvider) |
void |
FunctionSerializer.writeTo(JsonWriter writer,
ReplicationSpec additionalPropertiesProvider) |
void |
VersionCompatibleSerializer.writeTo(JsonWriter writer,
ReplicationSpec additionalPropertiesProvider) |
void |
TableSerializer.writeTo(JsonWriter writer,
ReplicationSpec additionalPropertiesProvider) |
void |
PartitionSerializer.writeTo(JsonWriter writer,
ReplicationSpec additionalPropertiesProvider) |
Modifier and Type | Method and Description |
---|---|
ReplicationSpec |
MetaData.getReplicationSpec() |
Constructor and Description |
---|
MetaData(Database db,
Table table,
Iterable<Partition> partitions,
ReplicationSpec replicationSpec,
Function function) |
Modifier and Type | Method and Description |
---|---|
ReplicationSpec |
ExportWork.getReplicationSpec() |
ReplicationSpec |
CreateFunctionDesc.getReplicationSpec() |
ReplicationSpec |
TruncateTableDesc.getReplicationSpec() |
ReplicationSpec |
CreateTableDesc.getReplicationSpec() |
ReplicationSpec |
DropFunctionDesc.getReplicationSpec() |
ReplicationSpec |
CreateViewDesc.getReplicationSpec() |
ReplicationSpec |
AlterDatabaseDesc.getReplicationSpec() |
ReplicationSpec |
ReplTxnWork.getReplicationSpec() |
ReplicationSpec |
DropTableDesc.getReplicationSpec() |
ReplicationSpec |
AddPartitionDesc.getReplicationSpec() |
ReplicationSpec |
RenamePartitionDesc.getReplicationSpec() |
ReplicationSpec |
DropDatabaseDesc.getReplicationSpec() |
ReplicationSpec |
AlterTableDesc.getReplicationSpec() |
Modifier and Type | Method and Description |
---|---|
void |
ImportTableDesc.setReplicationSpec(ReplicationSpec replSpec) |
void |
CreateTableDesc.setReplicationSpec(ReplicationSpec replicationSpec) |
void |
CreateViewDesc.setReplicationSpec(ReplicationSpec replicationSpec) |
void |
AddPartitionDesc.setReplicationSpec(ReplicationSpec replicationSpec) |
Constructor and Description |
---|
AlterDatabaseDesc(String databaseName,
Map<String,String> dbProps,
ReplicationSpec replicationSpec) |
AlterDatabaseDesc(String databaseName,
PrincipalDesc ownerPrincipal,
ReplicationSpec replicationSpec) |
AlterTableDesc(AlterTableDesc.AlterTableTypes alterType,
ReplicationSpec replicationSpec) |
AlterTableDesc(String tableName,
List<SQLPrimaryKey> primaryKeyCols,
List<SQLForeignKey> foreignKeyCols,
List<SQLUniqueConstraint> uniqueConstraintCols,
List<SQLNotNullConstraint> notNullConstraintCols,
List<SQLDefaultConstraint> defaultConstraints,
List<SQLCheckConstraint> checkConstraints,
ReplicationSpec replicationSpec) |
AlterTableDesc(String tableName,
List<SQLPrimaryKey> primaryKeyCols,
List<SQLForeignKey> foreignKeyCols,
List<SQLUniqueConstraint> uniqueConstraintCols,
ReplicationSpec replicationSpec) |
AlterTableDesc(String oldName,
String newName,
boolean expectView,
ReplicationSpec replicationSpec) |
AlterTableDesc(String tableName,
String dropConstraintName,
ReplicationSpec replicationSpec) |
CreateFunctionDesc(String functionName,
boolean isTemp,
String className,
List<ResourceUri> resources,
ReplicationSpec replicationSpec) |
DropDatabaseDesc(String databaseName,
boolean ifExists,
boolean cascade,
ReplicationSpec replicationSpec) |
DropDatabaseDesc(String databaseName,
boolean ifExists,
ReplicationSpec replicationSpec) |
DropFunctionDesc(String functionName,
boolean isTemp,
ReplicationSpec replicationSpec) |
DropTableDesc(String tableName,
Map<Integer,List<ExprNodeGenericFuncDesc>> partSpecs,
TableType expectedType,
boolean ifPurge,
ReplicationSpec replicationSpec) |
DropTableDesc(String tableName,
Map<Integer,List<ExprNodeGenericFuncDesc>> partSpecs,
TableType expectedType,
boolean ifPurge,
ReplicationSpec replicationSpec,
boolean validationRequired) |
DropTableDesc(String tableName,
TableType expectedType,
boolean ifExists,
boolean ifPurge,
ReplicationSpec replicationSpec) |
DropTableDesc(String tableName,
TableType expectedType,
boolean ifExists,
boolean ifPurge,
ReplicationSpec replicationSpec,
boolean validationRequired) |
ExportWork(String exportRootDirName,
BaseSemanticAnalyzer.TableSpec tableSpec,
ReplicationSpec replicationSpec,
String astRepresentationForErrorMsg,
String acidFqTableName,
ExportWork.MmContext mmContext) |
RenamePartitionDesc(String tableName,
Map<String,String> oldPartSpec,
Map<String,String> newPartSpec,
ReplicationSpec replicationSpec) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
List<Long> txnIds,
ReplTxnWork.OperationType type,
List<TxnToWriteId> txnToWriteIdList,
ReplicationSpec replicationSpec) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
List<Long> txnIds,
ReplTxnWork.OperationType type,
ReplicationSpec replicationSpec) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
Long txnId,
ReplTxnWork.OperationType type,
ReplicationSpec replicationSpec) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
ReplTxnWork.OperationType type,
List<TxnToWriteId> txnToWriteIdList,
ReplicationSpec replicationSpec) |
TruncateTableDesc(String tableName,
Map<String,String> partSpec,
ReplicationSpec replicationSpec) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.