Package org.apache.storm.redis.trident
Class WordCountStoreMapper
- java.lang.Object
-
- org.apache.storm.redis.trident.WordCountStoreMapper
-
- All Implemented Interfaces:
Serializable,RedisMapper,RedisStoreMapper,TupleMapper
public class WordCountStoreMapper extends Object implements RedisStoreMapper
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description WordCountStoreMapper()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RedisDataTypeDescriptiongetDataTypeDescription()Returns descriptor which defines data type.StringgetKeyFromTuple(ITuple tuple)Extracts key from tuple.StringgetValueFromTuple(ITuple tuple)Extracts value from tuple.
-
-
-
Method Detail
-
getDataTypeDescription
public RedisDataTypeDescription getDataTypeDescription()
Description copied from interface:RedisMapperReturns descriptor which defines data type.- Specified by:
getDataTypeDescriptionin interfaceRedisMapper- Returns:
- data type descriptor
-
getKeyFromTuple
public String getKeyFromTuple(ITuple tuple)
Description copied from interface:TupleMapperExtracts key from tuple.- Specified by:
getKeyFromTuplein interfaceTupleMapper- Parameters:
tuple- source tuple- Returns:
- key
-
getValueFromTuple
public String getValueFromTuple(ITuple tuple)
Description copied from interface:TupleMapperExtracts value from tuple.- Specified by:
getValueFromTuplein interfaceTupleMapper- Parameters:
tuple- source tuple- Returns:
- value
-
-