Package org.apache.storm.redis.trident
Class WordCountStoreMapper
java.lang.Object
org.apache.storm.redis.trident.WordCountStoreMapper
- All Implemented Interfaces:
Serializable,RedisMapper,RedisStoreMapper,TupleMapper
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionReturns descriptor which defines data type.getKeyFromTuple(ITuple tuple) Extracts key from tuple.getValueFromTuple(ITuple tuple) Extracts value from tuple.
-
Constructor Details
-
WordCountStoreMapper
public WordCountStoreMapper()
-
-
Method Details
-
getDataTypeDescription
Description copied from interface:RedisMapperReturns descriptor which defines data type.- Specified by:
getDataTypeDescriptionin interfaceRedisMapper- Returns:
- data type descriptor
-
getKeyFromTuple
Description copied from interface:TupleMapperExtracts key from tuple.- Specified by:
getKeyFromTuplein interfaceTupleMapper- Parameters:
tuple- source tuple- Returns:
- key
-
getValueFromTuple
Description copied from interface:TupleMapperExtracts value from tuple.- Specified by:
getValueFromTuplein interfaceTupleMapper- Parameters:
tuple- source tuple- Returns:
- value
-