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.
routingKeys
- public List<ByteBuffer> getRoutingKeys(ITuple tuple)
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.