Mercurial > hg > Members > shoshi > TreeCMSv2
view src/treecms/cassandra/CassandraForest.java @ 17:168deb591f21
commit
author | shoshi |
---|---|
date | Tue, 24 May 2011 00:33:12 +0900 |
parents | |
children | 019ca5abb1f0 |
line wrap: on
line source
package treecms.cassandra; import java.util.List; import java.util.Map; import java.util.Timer; import java.util.TimerTask; import java.util.concurrent.ConcurrentHashMap; import org.apache.cassandra.thrift.Mutation; import treecms.api.Forest; import treecms.api.MonotonicTree; import treecms.api.NodeID; import treecms.api.SingleNode; import treecms.api.Tree; import treecms.tree.util.NodeData; public class CassandraForest implements Forest { private Map<NodeID,SingleNode> m_nodeTable; private Map<String,SingleNode> m_tipTable; public CassandraForest() { m_nodeTable = new ConcurrentHashMap<NodeID,SingleNode>(); m_tipTable = new ConcurrentHashMap<String,SingleNode>(); } @Override public SingleNode get(NodeID _id) { return m_nodeTable.get(_id); } @Override public SingleNode getTip(String _uuid) { return m_tipTable.get(_uuid); } @Override public SingleNode create() { return null; } @Override public Tree getTree(SingleNode _root) { return null; } @Override public MonotonicTree getMonotonicTree(Tree _tree) { return null; } @Override public SingleNode create(NodeData<SingleNode> _data) { return null; } @Override public Tree getMainTree() { return null; } @Override public SingleNode create(NodeID _id, NodeData<SingleNode> _data) { return null; } private class CassandraNodeExporter extends TimerTask { private List<Mutation> m_updateQueue; @Override public void run() { } } private class CassandraNodeImporter extends TimerTask { @Override public void run() { } } }