Package com.zendesk.maxwell.row

Class RowMap

java.lang.Object

com.zendesk.maxwell.row.RowMap

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

DDLMap, HeartbeatRowMap

public class RowMap
extends Object
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RowMap.KeyFormat

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	suppressed

Constructor Summary

Constructors

Constructor	Description
RowMap(String type, String database, String table, Long timestampMillis, List<String> pkColumns, Position nextPosition)
RowMap(String type, String database, String table, Long timestampMillis, List<String> pkColumns, Position position, Position nextPosition, String rowQuery)
RowMap(String type, String database, String table, Long timestampMillis, List<String> pkColumns, Position nextPosition, String rowQuery)

Method Summary

Modifier and Type	Method	Description
String	buildPartitionKey(List<String> partitionColumns)
long	getApproximateSize()
String	getComment()
LinkedHashMap<String,Object>	getData()
Object	getData(String key)
String	getDatabase()
Object	getExtraAttribute(String key)
LinkedHashMap<String,Object>	getExtraAttributes()
String	getKafkaTopic()
Position	getNextPosition()
LinkedHashMap<String,Object>	getOldData()
Object	getOldData(String key)
String	getPartitionString()
Position	getPosition()
List<String>	getPrimaryKeyColumns()
Map<String,Object>	getPrimaryKeyMap()
List<Object>	getPrimaryKeyValues()
RowIdentity	getRowIdentity()
String	getRowQuery()
String	getRowType()
Long	getSchemaId()
Long	getServerId()
String	getTable()
Long	getThreadId()
Long	getTimestamp()
Long	getTimestampMillis()
Long	getXid()
Long	getXoffset()
boolean	hasData(String name)
boolean	isTXCommit()
String	pkToJson(RowMap.KeyFormat format)
void	putData(String key, Object value)
void	putExtraAttribute(String key, Object value)
void	putOldData(String key, Object value)
void	setComment(String comment)
void	setKafkaTopic(String topic)
void	setPartitionString(String partitionString)
void	setRowQuery(String query)
void	setSchemaId(Long schemaId)
void	setServerId(Long serverId)
void	setThreadId(Long threadId)
void	setTXCommit()
void	setXid(Long xid)
void	setXoffset(Long xoffset)
boolean	shouldOutput(MaxwellOutputConfig outputConfig)
void	suppress()
String	toJSON()
String	toJSON(MaxwellOutputConfig outputConfig)

Methods inherited from class java.lang.Object

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

Field Detail

suppressed

protected boolean suppressed

Constructor Detail

RowMap

public RowMap(String type,
              String database,
              String table,
              Long timestampMillis,
              List<String> pkColumns,
              Position position,
              Position nextPosition,
              String rowQuery)

RowMap

public RowMap(String type,
              String database,
              String table,
              Long timestampMillis,
              List<String> pkColumns,
              Position nextPosition,
              String rowQuery)

RowMap

public RowMap(String type,
              String database,
              String table,
              Long timestampMillis,
              List<String> pkColumns,
              Position nextPosition)

Method Detail

getRowIdentity

public RowIdentity getRowIdentity()

pkToJson

public String pkToJson(RowMap.KeyFormat format)
                throws IOException

Throws:

IOException

buildPartitionKey

public String buildPartitionKey(List<String> partitionColumns)

toJSON

public String toJSON()
              throws Exception

Throws:

Exception

toJSON

public String toJSON(MaxwellOutputConfig outputConfig)
              throws Exception

Throws:

Exception

getData

public Object getData(String key)

getExtraAttribute

public Object getExtraAttribute(String key)

getApproximateSize

public long getApproximateSize()

putData

public void putData(String key,
                    Object value)

putExtraAttribute

public void putExtraAttribute(String key,
                              Object value)

getOldData

public Object getOldData(String key)

putOldData

public void putOldData(String key,
                       Object value)

getNextPosition

public Position getNextPosition()

getPosition

public Position getPosition()

getXid

public Long getXid()

setXid

public void setXid(Long xid)

getXoffset

public Long getXoffset()

setXoffset

public void setXoffset(Long xoffset)

setTXCommit

public void setTXCommit()

isTXCommit

public boolean isTXCommit()

getServerId

public Long getServerId()

setServerId

public void setServerId(Long serverId)

getThreadId

public Long getThreadId()

setThreadId

public void setThreadId(Long threadId)

getSchemaId

public Long getSchemaId()

setSchemaId

public void setSchemaId(Long schemaId)

getDatabase

public String getDatabase()

getTable

public String getTable()

getTimestamp

public Long getTimestamp()

getTimestampMillis

public Long getTimestampMillis()

hasData

public boolean hasData(String name)

getRowQuery

public String getRowQuery()

setRowQuery

public void setRowQuery(String query)

getRowType

public String getRowType()

shouldOutput

public boolean shouldOutput(MaxwellOutputConfig outputConfig)

getData

public LinkedHashMap<String,Object> getData()

getExtraAttributes

public LinkedHashMap<String,Object> getExtraAttributes()

getOldData

public LinkedHashMap<String,Object> getOldData()

suppress

public void suppress()

getKafkaTopic

public String getKafkaTopic()

setKafkaTopic

public void setKafkaTopic(String topic)

getPartitionString

public String getPartitionString()

setPartitionString

public void setPartitionString(String partitionString)

getComment

public String getComment()

setComment

public void setComment(String comment)

getPrimaryKeyColumns

public List<String> getPrimaryKeyColumns()

getPrimaryKeyValues

public List<Object> getPrimaryKeyValues()

getPrimaryKeyMap

public Map<String,Object> getPrimaryKeyMap()