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 © 2021 The Apache Software Foundation. All rights reserved.