com.gigaspaces.dih.consumer

Class CDCInfo

java.lang.Object

com.gigaspaces.document.SpaceDocument

com.gigaspaces.dih.consumer.CDCInfo

All Implemented Interfaces:

VirtualEntry, SmartExternalizable, Externalizable, Serializable

public class CDCInfo
extends SpaceDocument

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	CDC_INFO

Constructor Summary

Constructors

Constructor and Description
CDCInfo()
CDCInfo(String pipelineName, Long messageID, Integer partitionID)

Method Summary

Modifier and Type	Method and Description
String	getID()
Long	getMessageID()
Integer	getPartitionID()
String	getPipelineName()
static SpaceTypeDescriptor	getTypeDescriptor()
CDCInfo	setID(String streamName, Integer partitionID)
CDCInfo	setMessageID(Long msgId)
CDCInfo	setPartitionID(Integer ptID)
CDCInfo	setPipelineName(String name)
String	toString()

Methods inherited from class com.gigaspaces.document.SpaceDocument

addProperties, containsProperty, equals, getProperties, getProperty, getTypeName, getVersion, hashCode, initFromDocument, initialize, isTransient, readExternal, readExternalV1, removeProperty, setProperty, setTransient, setTypeName, setVersion, writeExternal

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Field Detail

CDC_INFO

public static final String CDC_INFO

See Also:

Constant Field Values

Constructor Detail

CDCInfo

public CDCInfo()

CDCInfo

public CDCInfo(String pipelineName,
               Long messageID,
               Integer partitionID)

Method Detail

getTypeDescriptor

public static SpaceTypeDescriptor getTypeDescriptor()

setPipelineName

public CDCInfo setPipelineName(String name)

getPipelineName

public String getPipelineName()

setMessageID

public CDCInfo setMessageID(Long msgId)

getMessageID

public Long getMessageID()

setPartitionID

public CDCInfo setPartitionID(Integer ptID)

getPartitionID

public Integer getPartitionID()

setID

public CDCInfo setID(String streamName,
                     Integer partitionID)

getID

public String getID()

toString

public String toString()

Overrides:

toString in class SpaceDocument