@PublicEvolving public final class FixedKinesisPartitionKeyGenerator<T> extends Object implements PartitionKeyGenerator<T>
This is achieved by using the index of the producer task as a PartitionKey
.
Constructor and Description |
---|
FixedKinesisPartitionKeyGenerator() |
Modifier and Type | Method and Description |
---|---|
String |
apply(T record) |
boolean |
equals(Object o) |
int |
hashCode() |
void |
initialize(int indexOfThisSubtask,
int numberOfParallelSubtasks) |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
andThen, compose, identity
public void initialize(int indexOfThisSubtask, int numberOfParallelSubtasks)
public String apply(T record)
apply
in interface java.util.function.Function<T,String>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.