public class FieldNameBasedTupleToKafkaMapper<K,V> extends Object implements TridentTupleToKafkaMapper
| Modifier and Type | Field and Description |
|---|---|
String |
keyFieldName |
String |
msgFieldName |
| Constructor and Description |
|---|
FieldNameBasedTupleToKafkaMapper(String keyFieldName,
String msgFieldName) |
| Modifier and Type | Method and Description |
|---|---|
K |
getKeyFromTuple(TridentTuple tuple) |
V |
getMessageFromTuple(TridentTuple tuple) |
public final String keyFieldName
public final String msgFieldName
public K getKeyFromTuple(TridentTuple tuple)
getKeyFromTuple in interface TridentTupleToKafkaMapperpublic V getMessageFromTuple(TridentTuple tuple)
getMessageFromTuple in interface TridentTupleToKafkaMapperCopyright © 2021 The Apache Software Foundation. All rights reserved.