org.apache.hive.hcatalog.api.repl.exim

Class CreateTableReplicationTask

java.lang.Object

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

org.apache.hive.hcatalog.api.repl.exim.CreateTableReplicationTask

public class CreateTableReplicationTask
extends ReplicationTask

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
CreateTableReplicationTask(HCatNotificationEvent event)

Method Summary

Methods

Modifier and Type	Method and Description
Iterable<? extends Command>	getDstWhCommands() Returns a Iterable to send to a hive driver on the source warehouse If you *need* a List instead, you can use guava's ImmutableList.copyOf(iterable) or Lists.newArrayList(iterable) to get the underlying list, but this defeats the purpose of making this interface an Iterable rather than a List, since it is very likely that the number of Commands returned here will cause your process to run OOM.
Iterable<? extends Command>	getSrcWhCommands() Returns a Iterable to send to a hive driver on the source warehouse If you *need* a List instead, you can use guava's ImmutableList.copyOf(iterable) or Lists.newArrayList(iterable) to get the underlying list, but this defeats the purpose of making this interface an Iterable rather than a List, since it is very likely that the number of Commands returned here will cause your process to run OOM.
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, isActionable, 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

CreateTableReplicationTask

public CreateTableReplicationTask(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

getSrcWhCommands

public Iterable<? extends Command> getSrcWhCommands()

Description copied from class: ReplicationTask

Returns a Iterable to send to a hive driver on the source warehouse If you *need* a List instead, you can use guava's ImmutableList.copyOf(iterable) or Lists.newArrayList(iterable) to get the underlying list, but this defeats the purpose of making this interface an Iterable rather than a List, since it is very likely that the number of Commands returned here will cause your process to run OOM.

Specified by:

getSrcWhCommands in class ReplicationTask

getDstWhCommands

public Iterable<? extends Command> getDstWhCommands()

Description copied from class: ReplicationTask

Returns a Iterable to send to a hive driver on the source warehouse If you *need* a List instead, you can use guava's ImmutableList.copyOf(iterable) or Lists.newArrayList(iterable) to get the underlying list, but this defeats the purpose of making this interface an Iterable rather than a List, since it is very likely that the number of Commands returned here will cause your process to run OOM.

Specified by:

getDstWhCommands in class ReplicationTask