public class RoutingKeyGenerator extends Object implements Serializable
Constructor and Description |
---|
RoutingKeyGenerator(List<String> routingKeys)
Creates a new
RoutingKeyGenerator instance. |
Modifier and Type | Method and Description |
---|---|
List<ByteBuffer> |
getRoutingKeys(ITuple tuple) |
public RoutingKeyGenerator(List<String> routingKeys)
Creates a new RoutingKeyGenerator
instance.
public List<ByteBuffer> getRoutingKeys(ITuple tuple)
Copyright © 2022 The Apache Software Foundation. All rights reserved.