Package 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	Description
static final String	CDC_INFO

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

CDC_INFO

public static final String CDC_INFO

See Also:

• Constant Field Values

Constructor Details

CDCInfo

public CDCInfo()

CDCInfo

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

Method Details

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