org.apache.hadoop.hive.ql.parse

Class ReplicationSpec

java.lang.Object

org.apache.hadoop.hive.ql.parse.ReplicationSpec

public class ReplicationSpec
extends Object

Statements executed to handle replication have some additional information relevant to the replication subsystem - this class captures those bits of information. Typically, this corresponds to the replicationClause definition in the parser.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReplicationSpec.KEY
static class	ReplicationSpec.SCOPE

Constructor Summary

Constructors

Constructor and Description
ReplicationSpec() Default ctor that is useful for determining default states
ReplicationSpec(ASTNode node) Constructor to construct spec based on either the ASTNode that corresponds to the replication clause itself, or corresponds to the parent node, and will scan through the children to instantiate itself.
ReplicationSpec(boolean isInReplicationScope, boolean isMetadataOnly, String eventReplicationState, String currentReplicationState, boolean isNoop)
ReplicationSpec(com.google.common.base.Function<String,String> keyFetcher)

Method Summary

Methods

Modifier and Type	Method and Description
com.google.common.base.Predicate<Partition>	allowEventReplacementInto() Returns a predicate filter to filter an Iterable to return all partitions that the current replication event specification is allowed to replicate-replace-into
boolean	allowEventReplacementInto(Partition ptn) Determines if a current replication event specification is allowed to replicate-replace-into a given partition
boolean	allowEventReplacementInto(Table table) Determines if a current replication event specification is allowed to replicate-replace-into a given table
static boolean	allowReplacement(String currReplState, String replacementReplState)
boolean	allowReplacementInto(Partition ptn) Determines if a current replication object(current state of dump) is allowed to replicate-replace-into a given partition
boolean	allowReplacementInto(Table table) Determines if a current replication object(current state of dump) is allowed to replicate-replace-into a given table
String	get(ReplicationSpec.KEY key)
String	getCurrentReplicationState()
String	getReplicationState()
ReplicationSpec.SCOPE	getScope()
static boolean	isApplicable(ASTNode node) Tests if an ASTNode is a Replication Specification
boolean	isInReplicationScope()
boolean	isMetadataOnly()
boolean	isNoop()
void	setCurrentReplicationState(String currStateId)
void	setNoop(boolean isNoop)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationSpec

public ReplicationSpec(ASTNode node)

Constructor to construct spec based on either the ASTNode that corresponds to the replication clause itself, or corresponds to the parent node, and will scan through the children to instantiate itself.

Parameters:

node - replicationClause node, or parent of replicationClause node

ReplicationSpec

public ReplicationSpec()

Default ctor that is useful for determining default states

ReplicationSpec

public ReplicationSpec(boolean isInReplicationScope,
               boolean isMetadataOnly,
               String eventReplicationState,
               String currentReplicationState,
               boolean isNoop)

ReplicationSpec

public ReplicationSpec(com.google.common.base.Function<String,String> keyFetcher)

Method Detail

isApplicable

public static boolean isApplicable(ASTNode node)

Tests if an ASTNode is a Replication Specification

allowReplacement

public static boolean allowReplacement(String currReplState,
                       String replacementReplState)

Parameters:

currReplState - Current object state

replacementReplState - Replacement-candidate state

Returns:

whether or not a provided replacement candidate is newer(or equal) to the existing object state or not

allowReplacementInto

public boolean allowReplacementInto(Partition ptn)

Determines if a current replication object(current state of dump) is allowed to replicate-replace-into a given partition

allowEventReplacementInto

public boolean allowEventReplacementInto(Partition ptn)

Determines if a current replication event specification is allowed to replicate-replace-into a given partition

allowReplacementInto

public boolean allowReplacementInto(Table table)

Determines if a current replication object(current state of dump) is allowed to replicate-replace-into a given table

allowEventReplacementInto

public boolean allowEventReplacementInto(Table table)

Determines if a current replication event specification is allowed to replicate-replace-into a given table

allowEventReplacementInto

public com.google.common.base.Predicate<Partition> allowEventReplacementInto()

Returns a predicate filter to filter an Iterable to return all partitions that the current replication event specification is allowed to replicate-replace-into

isInReplicationScope

public boolean isInReplicationScope()

Returns:

true if this statement is being run for the purposes of replication

isMetadataOnly

public boolean isMetadataOnly()

Returns:

true if this statement refers to metadata-only operation.

getReplicationState

public String getReplicationState()

Returns:

the replication state of the event that spawned this statement

getCurrentReplicationState

public String getCurrentReplicationState()

Returns:

the current replication state of the wh

setCurrentReplicationState

public void setCurrentReplicationState(String currStateId)

isNoop

public boolean isNoop()

Returns:

whether or not the current replication action should be a noop

setNoop

public void setNoop(boolean isNoop)

Parameters:

isNoop - whether or not the current replication action should be a noop

get

public String get(ReplicationSpec.KEY key)

getScope

public ReplicationSpec.SCOPE getScope()