Package com.zendesk.maxwell.row

Class HeartbeatRowMap

java.lang.Object

com.zendesk.maxwell.row.RowMap

com.zendesk.maxwell.row.HeartbeatRowMap

All Implemented Interfaces:

Serializable

public class HeartbeatRowMap
extends RowMap

Created by ben on 9/7/16.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.zendesk.maxwell.row.RowMap

RowMap.KeyFormat

Field Summary

Fields inherited from class com.zendesk.maxwell.row.RowMap

suppressed

Constructor Summary

Constructors

Constructor	Description
HeartbeatRowMap(String database, Position position, Position nextPosition)

Method Summary

Modifier and Type	Method	Description
boolean	isTXCommit()
boolean	shouldOutput(MaxwellOutputConfig outputConfig)
String	toJSON()
String	toJSON(MaxwellOutputConfig outputConfig)
static HeartbeatRowMap	valueOf(String database, Position position, Position nextPosition)

Methods inherited from class com.zendesk.maxwell.row.RowMap

buildPartitionKey, getApproximateSize, getComment, getData, getData, getDatabase, getExtraAttribute, getExtraAttributes, getKafkaTopic, getNextPosition, getOldData, getOldData, getPartitionString, getPosition, getPrimaryKeyColumns, getPrimaryKeyMap, getPrimaryKeyValues, getRowIdentity, getRowQuery, getRowType, getSchemaId, getServerId, getTable, getThreadId, getTimestamp, getTimestampMillis, getXid, getXoffset, hasData, pkToJson, putData, putExtraAttribute, putOldData, setComment, setKafkaTopic, setPartitionString, setRowQuery, setSchemaId, setServerId, setThreadId, setTXCommit, setXid, setXoffset, suppress

Methods inherited from class java.lang.Object

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

Constructor Detail

HeartbeatRowMap

public HeartbeatRowMap(String database,
                       Position position,
                       Position nextPosition)

Method Detail

valueOf

public static HeartbeatRowMap valueOf(String database,
                                      Position position,
                                      Position nextPosition)

toJSON

public String toJSON(MaxwellOutputConfig outputConfig)
              throws IOException

Overrides:

toJSON in class RowMap

Throws:

IOException

toJSON

public String toJSON()
              throws IOException

Overrides:

toJSON in class RowMap

Throws:

IOException

isTXCommit

public boolean isTXCommit()

Overrides:

isTXCommit in class RowMap

shouldOutput

public boolean shouldOutput(MaxwellOutputConfig outputConfig)

Overrides:

shouldOutput in class RowMap