org.apache.hive.hcatalog.api.repl

Class ErroredReplicationTask

java.lang.Object

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

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

org.apache.hive.hcatalog.api.repl.ErroredReplicationTask

public class ErroredReplicationTask
extends NoopReplicationTask

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. This is used to protect "future" events that we know nothing about from breaking the system by throwing IllegalStateExceptions. Whether or not the user intends to do something with these tasks and act upon the exceptions is left to the user to determine how they can best use them.

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
ErroredReplicationTask(HCatNotificationEvent event, RuntimeException e)

Method Summary

Modifier and Type	Method and Description
RuntimeException	getCause()
boolean	isActionable() Returns true if this ReplicationTask is prepared with all info it needs, and is ready to be used

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

getDstWhCommands, getSrcWhCommands, needsStagingDirs

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

ErroredReplicationTask

public ErroredReplicationTask(HCatNotificationEvent event,
                              RuntimeException e)

Method Detail

getCause

public RuntimeException getCause()

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 NoopReplicationTask