|
17
|
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 }
|
