org.apache.beam.sdk.io.kinesis

Interface KinesisPartitioner

All Superinterfaces:

java.io.Serializable

public interface KinesisPartitioner
extends java.io.Serializable

Kinesis interface for custom partitioner.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getExplicitHashKey(byte[] value)
java.lang.String	getPartitionKey(byte[] value)

Method Detail

getPartitionKey

java.lang.String getPartitionKey(byte[] value)

getExplicitHashKey

java.lang.String getExplicitHashKey(byte[] value)