Package com.zendesk.maxwell.producer.partitioners

Class MaxwellKinesisPartitioner

java.lang.Object

com.zendesk.maxwell.producer.partitioners.AbstractMaxwellPartitioner

com.zendesk.maxwell.producer.partitioners.MaxwellKinesisPartitioner

public class MaxwellKinesisPartitioner
extends AbstractMaxwellPartitioner

Constructor Summary

Constructors

Constructor	Description
MaxwellKinesisPartitioner(String partitionKey, String csvPartitionColumns, String partitionKeyFallback, boolean md5Keys)

Method Summary

Modifier and Type	Method	Description
String	getKinesisKey(RowMap r)

Methods inherited from class com.zendesk.maxwell.producer.partitioners.AbstractMaxwellPartitioner

getDatabase, getHashString, getHashString, getTable

Methods inherited from class java.lang.Object

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

Constructor Detail

MaxwellKinesisPartitioner

public MaxwellKinesisPartitioner(String partitionKey,
                                 String csvPartitionColumns,
                                 String partitionKeyFallback,
                                 boolean md5Keys)

Method Detail

getKinesisKey

public String getKinesisKey(RowMap r)