org.apache.flink.connector.kinesis.sink

Interface PartitionKeyGenerator<InputT>

All Superinterfaces:

java.util.function.Function<InputT,String>, Serializable

All Known Implementing Classes:

FixedKinesisPartitionKeyGenerator, KinesisPartitioner, RandomKinesisPartitionKeyGenerator, RowDataFieldsKinesisPartitionKeyGenerator

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@PublicEvolving
 @FunctionalInterface
public interface PartitionKeyGenerator<InputT>
extends java.util.function.Function<InputT,String>, Serializable

This is a serializable function whose accept() method specifies how to convert from an input element to the partition key, a string.

Method Summary

Methods inherited from interface java.util.function.Function

andThen, apply, compose, identity