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)
RoutingKeyGenerator
instance.public List<ByteBuffer> getRoutingKeys(ITuple tuple)
Copyright © 2023 The Apache Software Foundation. All rights reserved.