CassandraTopic_yaml.py
Go to the documentation of this file.
00001 import pycassa
00002 import yaml
00003 
00004 from CassandraTopic_ import *
00005 
00006 class CassandraTopic_yaml(CassandraTopic_):
00007     def __init__(self, MsgClass):        
00008         CassandraTopic_.__init__(MsgClass)
00009         
00010     def getColumnValidationClasses(self):
00011         return {'yaml' : pycassa.BYTES_TYPE}
00012     
00013     def encode(self, msg):
00014         return {"yaml" : str(yaml.dump(msg))}
00015     
00016     def decode(self, data):
00017         return yaml.load(data["yaml"])


cassandra_ros
Author(s): André Dietrich, Sebastian Zug
autogenerated on Mon Oct 6 2014 10:13:55