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
-
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:RedisMapper
Returns descriptor which defines data type.- Specified by:
getDataTypeDescription
in interfaceRedisMapper
- Returns:
- data type descriptor
-
getKeyFromTuple
Description copied from interface:TupleMapper
Extracts key from tuple.- Specified by:
getKeyFromTuple
in interfaceTupleMapper
- Parameters:
tuple
- source tuple- Returns:
- key
-
getValueFromTuple
Description copied from interface:TupleMapper
Extracts value from tuple.- Specified by:
getValueFromTuple
in interfaceTupleMapper
- Parameters:
tuple
- source tuple- Returns:
- value
-