org.apache.hive.hcatalog.api.repl

Class NoopReplicationTask

java.lang.Object

org.apache.hive.hcatalog.api.repl.ReplicationTask

org.apache.hive.hcatalog.api.repl.NoopReplicationTask

Direct Known Subclasses:

CreateDatabaseReplicationTask

public class NoopReplicationTask
extends ReplicationTask

Noop replication task - a replication task that is actionable, does not need any further info, and returns NoopCommands. Useful for testing, and also for tasks that need to be represented but actually do nothing.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hive.hcatalog.api.repl.ReplicationTask

ReplicationTask.Factory

Field Summary

Fields inherited from class org.apache.hive.hcatalog.api.repl.ReplicationTask

dbNameMapping, dstStagingDirProvider, event, messageFactory, srcStagingDirProvider, tableNameMapping

Constructor Summary

Constructors

Constructor and Description
NoopReplicationTask(HCatNotificationEvent event)

Method Summary

Methods

Modifier and Type	Method and Description
Iterable<? extends Command>	getDstWhCommands() Returns a list of commands to send to a hive driver on the dest warehouse
Iterable<? extends Command>	getSrcWhCommands() Returns a list of commands to send to a hive driver on the source warehouse
boolean	isActionable() Returns true if this ReplicationTask is prepared with all info it needs, and is ready to be used
boolean	needsStagingDirs() Returns true if the replication task in question needs to create staging directories to complete its operation.

Methods inherited from class org.apache.hive.hcatalog.api.repl.ReplicationTask

create, getEvent, resetFactory, validateEventType, verifyActionable, withDbNameMapping, withDstStagingDirProvider, withSrcStagingDirProvider, withTableNameMapping

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopReplicationTask

public NoopReplicationTask(HCatNotificationEvent event)

Method Detail

needsStagingDirs

public boolean needsStagingDirs()

Description copied from class: ReplicationTask

Returns true if the replication task in question needs to create staging directories to complete its operation. This will mean that you will need to copy these directories over to the destination warehouse for each source-destination warehouse pair. If this is true, you will need to call .withSrcStagingDirProvider(...) and .withDstStagingDirProvider(...) before this ReplicationTask is usable

Specified by:

needsStagingDirs in class ReplicationTask

isActionable

public boolean isActionable()

Description copied from class: ReplicationTask

Returns true if this ReplicationTask is prepared with all info it needs, and is ready to be used

Overrides:

isActionable in class ReplicationTask

getSrcWhCommands

public Iterable<? extends Command> getSrcWhCommands()

Returns a list of commands to send to a hive driver on the source warehouse

Specified by:

getSrcWhCommands in class ReplicationTask

Returns:

a list of commands to send to a hive driver on the source warehouse

getDstWhCommands

public Iterable<? extends Command> getDstWhCommands()

Returns a list of commands to send to a hive driver on the dest warehouse

Specified by:

getDstWhCommands in class ReplicationTask

Returns:

a list of commands to send to a hive driver on the dest warehouse