Package com.zendesk.maxwell.schema.ddl

Class DDLMap

java.lang.Object

com.zendesk.maxwell.row.RowMap

com.zendesk.maxwell.schema.ddl.DDLMap

All Implemented Interfaces:

Serializable

public class DDLMap
extends RowMap

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
DDLMap(ResolvedSchemaChange change, Long timestamp, String sql, Position position, Position nextPosition, Long schemaId)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	getChangeMap()
String	getSql()
boolean	isTXCommit()
String	pkToJson(RowMap.KeyFormat keyFormat)
boolean	shouldOutput(MaxwellOutputConfig outputConfig)
String	toJSON()
String	toJSON(MaxwellOutputConfig outputConfig)

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, 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

DDLMap

public DDLMap(ResolvedSchemaChange change,
              Long timestamp,
              String sql,
              Position position,
              Position nextPosition,
              Long schemaId)

Method Detail

pkToJson

public String pkToJson(RowMap.KeyFormat keyFormat)
                throws IOException

Overrides:

pkToJson in class RowMap

Throws:

IOException

isTXCommit

public boolean isTXCommit()

Overrides:

isTXCommit in class RowMap

toJSON

public String toJSON()
              throws IOException

Overrides:

toJSON in class RowMap

Throws:

IOException

getChangeMap

public Map<String,Object> getChangeMap()

toJSON

public String toJSON(MaxwellOutputConfig outputConfig)
              throws IOException

Overrides:

toJSON in class RowMap

Throws:

IOException

shouldOutput

public boolean shouldOutput(MaxwellOutputConfig outputConfig)

Overrides:

shouldOutput in class RowMap

getSql

public String getSql()