Uses of Class
com.zendesk.maxwell.row.RowMap

Packages that use RowMap

Package	Description
com.zendesk.maxwell	top level classes concerned with instantiating and running a Maxwell replicator.
com.zendesk.maxwell.bootstrap	bootstrapping outputs the current dataset into a stream.
com.zendesk.maxwell.producer	producers write to streams and sinks of various types.
com.zendesk.maxwell.producer.partitioners	partitioners deal with subdividing streams by data key
com.zendesk.maxwell.replication	concerns the operation of the binlog replicator
com.zendesk.maxwell.row	Maxwell's representation of a row from the binlog
com.zendesk.maxwell.schema.ddl	the mysql DDL schema parser lives here.
com.zendesk.maxwell.scripting	interfaces and code for javascript filters
com.zendesk.maxwell.util	grab-bag of code

Uses of RowMap in com.zendesk.maxwell

Methods in com.zendesk.maxwell that return RowMap

Modifier and Type	Method	Description
RowMap	BufferedMaxwell.poll(long ms)	Poll for a RowMap to be producer by the maxwell instance.

Methods in com.zendesk.maxwell with parameters of type RowMap

Modifier and Type	Method	Description
void	MaxwellContext.setPosition(RowMap r)	If the passed RowMap is a transaction-commit, update maxwell's position

Uses of RowMap in com.zendesk.maxwell.bootstrap

Methods in com.zendesk.maxwell.bootstrap with parameters of type RowMap

Modifier and Type	Method	Description
boolean	BootstrapTask.matches(RowMap row)
boolean	BootstrapController.shouldSkip(RowMap row)	If a bootstrap is active for a table, buffer the row for later.
static BootstrapTask	BootstrapTask.valueOf(RowMap row)

Uses of RowMap in com.zendesk.maxwell.producer

Methods in com.zendesk.maxwell.producer that return RowMap

Modifier and Type	Method	Description
RowMap	BufferedProducer.poll(long timeout, TimeUnit unit)

Methods in com.zendesk.maxwell.producer with parameters of type RowMap

Modifier and Type	Method	Description
void	AbstractAsyncProducer.push(RowMap r)
abstract void	AbstractProducer.push(RowMap r)
void	AbstractProfilingProducer.push(RowMap r)
void	BufferedProducer.push(RowMap r)
void	FileProducer.push(RowMap r)
void	MaxwellBigQueryProducer.push(RowMap r)
void	MaxwellKafkaProducer.push(RowMap r)
void	MaxwellPubsubProducer.push(RowMap r)
void	MaxwellRedisProducer.push(RowMap r)
void	NatsProducer.push(RowMap r)
void	NoneProducer.push(RowMap r)
void	ProfilerProducer.push(RowMap r)
void	RabbitmqProducer.push(RowMap r)
void	StdoutProducer.push(RowMap r)
abstract void	AbstractAsyncProducer.sendAsync(RowMap r, AbstractAsyncProducer.CallbackCompleter cc)
void	MaxwellKinesisProducer.sendAsync(RowMap r, AbstractAsyncProducer.CallbackCompleter cc)
void	MaxwellSNSProducer.sendAsync(RowMap r, AbstractAsyncProducer.CallbackCompleter cc)
void	MaxwellSQSProducer.sendAsync(RowMap r, AbstractAsyncProducer.CallbackCompleter cc)

Uses of RowMap in com.zendesk.maxwell.producer.partitioners

Methods in com.zendesk.maxwell.producer.partitioners with parameters of type RowMap

Modifier and Type	Method	Description
protected static String	AbstractMaxwellPartitioner.getDatabase(RowMap r)
String	AbstractMaxwellPartitioner.getHashString(RowMap r)
String	AbstractMaxwellPartitioner.getHashString(RowMap r, PartitionBy by)
String	MaxwellKinesisPartitioner.getKinesisKey(RowMap r)
protected static String	AbstractMaxwellPartitioner.getTable(RowMap r)
int	MaxwellKafkaPartitioner.kafkaPartition(RowMap r, int numPartitions)

Uses of RowMap in com.zendesk.maxwell.replication

Methods in com.zendesk.maxwell.replication that return RowMap

Modifier and Type	Method	Description
RowMap	BinlogConnectorReplicator.getRow()	The main entry point into the event reading loop.
RowMap	Replicator.getRow()

Methods in com.zendesk.maxwell.replication that return types with arguments of type RowMap

Modifier and Type	Method	Description
List<RowMap>	BinlogConnectorEvent.jsonMaps(Table table, long lastHeartbeatRead, String rowQuery)

Methods in com.zendesk.maxwell.replication with parameters of type RowMap

Modifier and Type	Method	Description
protected boolean	BinlogConnectorReplicator.isMaxwellRow(RowMap row)	Is this RowMap an update to one of maxwell's own tables? We don't output updates to maxwell.positions, and updates to maxwell.heartbeats are always treated specially.
protected void	BinlogConnectorReplicator.processRow(RowMap row)

Uses of RowMap in com.zendesk.maxwell.row

Subclasses of RowMap in com.zendesk.maxwell.row

Modifier and Type	Class	Description
class	HeartbeatRowMap	Created by ben on 9/7/16.

Methods in com.zendesk.maxwell.row that return RowMap

Modifier and Type	Method	Description
static RowMap	RowMapDeserializer.createFromString(String json)
static RowMap	RowMapDeserializer.createFromString(String json, String secret_key)
RowMap	RowMapDeserializer.deserialize(com.fasterxml.jackson.core.JsonParser jsonParser, com.fasterxml.jackson.databind.DeserializationContext deserializationContext)
protected RowMap	RowMapBuffer.evict()
RowMap	RowMapBuffer.removeFirst()
RowMap	RowMapBufferByTable.removeFirst(String databaseName, String tableName)

Methods in com.zendesk.maxwell.row with parameters of type RowMap

Modifier and Type	Method	Description
void	RowMapBuffer.add(RowMap rowMap)
void	RowMapBufferByTable.add(RowMap row)

Uses of RowMap in com.zendesk.maxwell.schema.ddl

Subclasses of RowMap in com.zendesk.maxwell.schema.ddl

Modifier and Type	Class	Description
class	DDLMap

Uses of RowMap in com.zendesk.maxwell.scripting

Methods in com.zendesk.maxwell.scripting with parameters of type RowMap

Modifier and Type	Method	Description
void	Scripting.invoke(RowMap row)

Constructors in com.zendesk.maxwell.scripting with parameters of type RowMap

Constructor	Description
WrappedRowMap(RowMap row)

Uses of RowMap in com.zendesk.maxwell.util

Methods in com.zendesk.maxwell.util with parameters of type RowMap

Modifier and Type	Method	Description
String	TopicInterpolator.generateFromRowMap(RowMap r)	Interpolate the input string based on {{RowMap}}
String	TopicInterpolator.generateFromRowMapAndCleanUpIllegalCharacters(RowMap r)	Interpolate the input string based on {{RowMap}} and clean up all non alpha-numeric characters