Mercurial > hg > Members > shoshi > TreeCMSv2

comparison src/treecms/cassandra/CassandraForest.java @ 17:168deb591f21

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
commit
author shoshi
date Tue, 24 May 2011 00:33:12 +0900
parents
children 019ca5abb1f0
comparison
equal deleted inserted replaced
16:bb9760760744 17:168deb591f21
1 package treecms.cassandra;
2
3 import java.util.List;
4 import java.util.Map;
5 import java.util.Timer;
6 import java.util.TimerTask;
7 import java.util.concurrent.ConcurrentHashMap;
8
9 import org.apache.cassandra.thrift.Mutation;
10
11 import treecms.api.Forest;
12 import treecms.api.MonotonicTree;
13 import treecms.api.NodeID;
14 import treecms.api.SingleNode;
15 import treecms.api.Tree;
16 import treecms.tree.util.NodeData;
17
18
19 public class CassandraForest implements Forest
20 {
21 private Map<NodeID,SingleNode> m_nodeTable;
22 private Map<String,SingleNode> m_tipTable;
23
24 public CassandraForest()
25 {
26 m_nodeTable = new ConcurrentHashMap<NodeID,SingleNode>();
27 m_tipTable = new ConcurrentHashMap<String,SingleNode>();
28 }
29
30 @Override
31 public SingleNode get(NodeID _id)
32 {
33 return m_nodeTable.get(_id);
34 }
35
36 @Override
37 public SingleNode getTip(String _uuid)
38 {
39 return m_tipTable.get(_uuid);
40 }
41
42 @Override
43 public SingleNode create()
44 {
45 return null;
46 }
47
48 @Override
49 public Tree getTree(SingleNode _root)
50 {
51 return null;
52 }
53
54 @Override
55 public MonotonicTree getMonotonicTree(Tree _tree)
56 {
57 return null;
58 }
59
60 @Override
61 public SingleNode create(NodeData<SingleNode> _data)
62 {
63 return null;
64 }
65
66 @Override
67 public Tree getMainTree()
68 {
69 return null;
70 }
71
72 @Override
73 public SingleNode create(NodeID _id, NodeData<SingleNode> _data)
74 {
75 return null;
76 }
77
78 private class CassandraNodeExporter extends TimerTask
79 {
80 private List<Mutation> m_updateQueue;
81
82 @Override
83 public void run()
84 {
85 }
86 }
87
88 private class CassandraNodeImporter extends TimerTask
89 {
90 @Override
91 public void run()
92 {
93 }
94 }
95 }