public class ReplicationRequest extends CloneableDataObject
Title: Dataspace Framework
Description: Wrapper for the replication management request.
Copyright: Copyright (c) 2012
Company: StreamScape Technologies
Modifier and Type | Class and Description |
---|---|
static class |
ReplicationRequest.RequestType |
DEFAULT_SERIAL_VERSION_ID
Constructor and Description |
---|
ReplicationRequest(ReplicationRequest.RequestType operationType) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
clone()
Clones the object.
|
int |
getCollectionType() |
int |
getFetchSize() |
ReplicationRequest.RequestType |
getOperation() |
java.util.List |
getPrimaryKey() |
ReplicationEntityName |
getReplicaEntityName() |
ReplicaState |
getReplicaState() |
long |
getReplicationId() |
long |
getRequestTimeout() |
int |
getRetryCount() |
com.streamscape.ds.session.Session |
getSession() |
java.lang.String |
getSourceName() |
long |
getSourceTableSchemaChangeTimestamp() |
java.lang.String |
getSql() |
boolean |
isAppend() |
boolean |
isAsync() |
boolean |
isRollbackOnFailure() |
boolean |
isSuspended() |
boolean |
isWithMetrics() |
void |
setAppend(boolean append) |
void |
setAsync(boolean isAsync) |
void |
setCollectionType(int collectionType) |
void |
setFetchSize(int fetchSize) |
void |
setPrimaryKey(java.util.List primaryKey) |
void |
setReplicaEntityName(ReplicationEntityName replicaEntityName) |
void |
setReplicaState(ReplicaState replicaState) |
void |
setReplicationId(long replicationId) |
void |
setRequestTimeout(long requestTimeout) |
void |
setRetryCount(int retryCount) |
void |
setRollbackOnFailure(boolean rollbackOnFailure) |
void |
setSession(com.streamscape.ds.session.Session session) |
void |
setSourceName(java.lang.String collectionName) |
void |
setSourceTableSchemaChangeTimestamp(long sourceTableSchemaChangeTimestamp) |
void |
setSql(java.lang.String sql) |
void |
setSuspended(boolean isSuspended) |
void |
setWithMetrics(boolean withMetrics) |
getSerialVersionUID
public ReplicationRequest(ReplicationRequest.RequestType operationType)
public ReplicationRequest.RequestType getOperation()
public java.lang.String getSourceName()
public void setSourceName(java.lang.String collectionName)
public int getCollectionType()
public void setCollectionType(int collectionType)
public boolean isAsync()
public void setAsync(boolean isAsync)
public int getFetchSize()
public void setFetchSize(int fetchSize)
public long getRequestTimeout()
public void setRequestTimeout(long requestTimeout)
public boolean isAppend()
public void setAppend(boolean append)
public long getReplicationId()
public void setReplicationId(long replicationId)
public ReplicaState getReplicaState()
public void setReplicaState(ReplicaState replicaState)
public void setSuspended(boolean isSuspended)
public boolean isSuspended()
public void setReplicaEntityName(ReplicationEntityName replicaEntityName)
public ReplicationEntityName getReplicaEntityName()
public com.streamscape.ds.session.Session getSession()
public void setSession(com.streamscape.ds.session.Session session)
public void setSql(java.lang.String sql)
public java.lang.String getSql()
public java.util.List getPrimaryKey()
public void setPrimaryKey(java.util.List primaryKey)
public void setRetryCount(int retryCount)
public int getRetryCount()
public void setWithMetrics(boolean withMetrics)
public boolean isWithMetrics()
public boolean isRollbackOnFailure()
public void setRollbackOnFailure(boolean rollbackOnFailure)
public void setSourceTableSchemaChangeTimestamp(long sourceTableSchemaChangeTimestamp)
public long getSourceTableSchemaChangeTimestamp()
public java.lang.Object clone()
CloneableDataObject
clone
in interface CloneableObject
clone
in class CloneableDataObject
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.