Package | Description |
---|---|
org.apache.hive.hcatalog.api | |
org.apache.hive.hcatalog.api.repl | |
org.apache.hive.hcatalog.api.repl.exim |
Modifier and Type | Method and Description |
---|---|
abstract Iterator<ReplicationTask> |
HCatClient.getReplicationTasks(long lastEventId,
int maxEvents,
String dbName,
String tableName)
Get an iterator that iterates over a list of replication tasks needed to replicate all the
events that have taken place for a given db/table.
|
Iterator<ReplicationTask> |
HCatClientHMSImpl.getReplicationTasks(long lastEventId,
int maxEvents,
String dbName,
String tableName) |
Modifier and Type | Class and Description |
---|---|
class |
ErroredReplicationTask
ErroredReplicationTask is a special kind of NoopReplicationTask in that it
is not actionable, and wraps an error that might have occurred during Task
instantiation time.
|
class |
NoopReplicationTask
Noop replication task - a replication task that is actionable,
does not need any further info, and returns NoopCommands.
|
Modifier and Type | Method and Description |
---|---|
static ReplicationTask |
ReplicationTask.create(HCatClient client,
HCatNotificationEvent event)
Factory method to return appropriate subtype of ReplicationTask for given event
|
ReplicationTask |
ReplicationTask.Factory.create(HCatClient client,
HCatNotificationEvent event) |
ReplicationTask |
HCatReplicationTaskIterator.next() |
ReplicationTask |
ReplicationTask.withDbNameMapping(com.google.common.base.Function<String,String> dbNameMapping)
Allows a user to specify a db name mapping, where the the function provided maps the name of
the db in the source warehouse to the name of the db in the dest warehouse.
|
ReplicationTask |
ReplicationTask.withDstStagingDirProvider(StagingDirectoryProvider dstStagingDirProvider)
|
ReplicationTask |
ReplicationTask.withSrcStagingDirProvider(StagingDirectoryProvider srcStagingDirProvider)
|
ReplicationTask |
ReplicationTask.withTableNameMapping(com.google.common.base.Function<String,String> tableNameMapping)
Allows a user to specify a table name mapping, where the the function provided maps the name of
the table in the source warehouse to the name of the table in the dest warehouse.
|
Modifier and Type | Class and Description |
---|---|
class |
AddPartitionReplicationTask |
class |
AlterPartitionReplicationTask |
class |
AlterTableReplicationTask |
class |
CreateDatabaseReplicationTask |
class |
CreateTableReplicationTask |
class |
DropDatabaseReplicationTask |
class |
DropPartitionReplicationTask |
class |
DropTableReplicationTask |
class |
InsertReplicationTask |
Modifier and Type | Method and Description |
---|---|
ReplicationTask |
EximReplicationTaskFactory.create(HCatClient client,
HCatNotificationEvent event) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.