@@ -0,0 +1,937 @@
+%0Aclass MyMethod(object):%0A    def __init__(self, graph, clusters):%0A        self.graph = graph%0A        self.clusters = clusters%0A        self.count_partitions = %7B%7D%0A%0A    def __get_count(self):%0A        abstraction = %5B%5D%0A        for cluster_id, nodes in self.clusters.iteritems():%0A            if len(nodes) %3E 1:%0A                for node_id in nodes:%0A                    message = self.graph.node%5Bnode_id%5D%5B'preprocessed_event'%5D%0A%0A                    # get count%0A                    tokens = message.strip().split()%0A                    token_count = len(tokens)%0A%0A                    partition_keys = self.count_partitions.keys()%0A                    if token_count not in partition_keys:%0A                        self.count_partitions%5Btoken_count%5D = %5B%5D%0A                    self.count_partitions%5Btoken_count%5D.append(message)%0A%0A            elif len(nodes) == 1:%0A                abstraction%5Bcluster_id%5D = self.graph.node%5Bnodes%5B0%5D%5D%5B'preprocessed_event'%5D%0A

Add new method for abstraction