Package com.zendesk.maxwell.producer.partitioners

Class AbstractMaxwellPartitioner

java.lang.Object

com.zendesk.maxwell.producer.partitioners.AbstractMaxwellPartitioner

Direct Known Subclasses:

MaxwellKafkaPartitioner, MaxwellKinesisPartitioner

public abstract class AbstractMaxwellPartitioner
extends Object

Constructor Summary

Constructors

Constructor	Description
AbstractMaxwellPartitioner(String partitionKey, String csvPartitionColumns, String partitionKeyFallback)

Method Summary

Modifier and Type	Method	Description
protected static String	getDatabase(RowMap r)
String	getHashString(RowMap r)
String	getHashString(RowMap r, PartitionBy by)
protected static String	getTable(RowMap r)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMaxwellPartitioner

public AbstractMaxwellPartitioner(String partitionKey,
                                  String csvPartitionColumns,
                                  String partitionKeyFallback)

Method Detail

getDatabase

protected static String getDatabase(RowMap r)

getTable

protected static String getTable(RowMap r)

getHashString

public String getHashString(RowMap r,
                            PartitionBy by)

getHashString

public String getHashString(RowMap r)