public class FieldNameBasedTupleToMessageMapper extends Object implements TupleToMessageMapper
| Modifier and Type | Field and Description |
|---|---|
static String |
BOLT_KEY |
static String |
BOLT_MESSAGE |
String |
boltKeyField |
String |
boltMessageField |
| Constructor and Description |
|---|
FieldNameBasedTupleToMessageMapper() |
FieldNameBasedTupleToMessageMapper(String boltKeyField,
String boltMessageField)
FieldNameBasedTupleToMessageMapper Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
String |
getKeyFromTuple(ITuple tuple) |
byte[] |
getValueFromTuple(ITuple tuple) |
FieldNameBasedTupleToMessageMapper |
withMessageBodySerializer(MessageBodySerializer serializer)
using this method can override the default MessageBodySerializer.
|
public static final String BOLT_KEY
public static final String BOLT_MESSAGE
public String boltKeyField
public String boltMessageField
public String getKeyFromTuple(ITuple tuple)
getKeyFromTuple in interface TupleToMessageMapperpublic byte[] getValueFromTuple(ITuple tuple)
getValueFromTuple in interface TupleToMessageMapperpublic FieldNameBasedTupleToMessageMapper withMessageBodySerializer(MessageBodySerializer serializer)
using this method can override the default MessageBodySerializer.
serializer - MessageBodySerializerCopyright © 2021 The Apache Software Foundation. All rights reserved.