Mercurial > hg > Members > shoshi > TreeCMSv2
comparison src/treecms/tree/cassandra/v1/util/ConcurrentCassandraClient.java @ 11:85061e874775
commit
author | shoshi |
---|---|
date | Fri, 06 May 2011 00:42:57 +0900 |
parents | 4e0ed81bea89 |
children |
comparison
equal
deleted
inserted
replaced
10:4e0ed81bea89 | 11:85061e874775 |
---|---|
1 package treecms.tree.cassandra.v1.util; | 1 package treecms.tree.cassandra.v1.util; |
2 | 2 |
3 import java.util.concurrent.Callable; | 3 import java.util.concurrent.Callable; |
4 import java.util.List; | |
5 import java.util.Map; | |
4 import java.util.concurrent.ExecutorService; | 6 import java.util.concurrent.ExecutorService; |
5 import java.util.concurrent.Executors; | 7 import java.util.concurrent.Executors; |
6 import java.util.concurrent.Future; | 8 import java.util.concurrent.Future; |
7 import java.util.concurrent.TimeUnit; | 9 import java.util.concurrent.TimeUnit; |
8 | 10 |
9 import org.apache.cassandra.thrift.ColumnOrSuperColumn; | 11 import org.apache.cassandra.thrift.ColumnOrSuperColumn; |
12 import org.apache.cassandra.thrift.ColumnParent; | |
10 import org.apache.cassandra.thrift.ColumnPath; | 13 import org.apache.cassandra.thrift.ColumnPath; |
11 import org.apache.cassandra.thrift.ConsistencyLevel; | 14 import org.apache.cassandra.thrift.ConsistencyLevel; |
15 import org.apache.cassandra.thrift.Mutation; | |
16 import org.apache.cassandra.thrift.SlicePredicate; | |
12 | 17 |
13 /** | 18 /** |
14 * | 19 * |
15 * @author shoshi | 20 * @author shoshi |
16 */ | 21 */ |
53 | 58 |
54 Future<ColumnOrSuperColumn> ret = m_service.submit(task); | 59 Future<ColumnOrSuperColumn> ret = m_service.submit(task); |
55 return ret; | 60 return ret; |
56 } | 61 } |
57 | 62 |
63 public Future<List<ColumnOrSuperColumn>> get_slice(final String _ks,final String _key,final ColumnParent _parent,final SlicePredicate _predicate,final ConsistencyLevel _level) | |
64 { | |
65 Callable<List<ColumnOrSuperColumn>> task = new Callable<List<ColumnOrSuperColumn>>(){ | |
66 @Override | |
67 public List<ColumnOrSuperColumn> call() throws Exception | |
68 { | |
69 CassandraClientWrapper client = ((CassandraClientThread)Thread.currentThread()).getClientWrapper(); | |
70 List<ColumnOrSuperColumn> ret = client.get_slice(_ks,_key,_parent,_predicate,_level); | |
71 return ret; | |
72 } | |
73 }; | |
74 | |
75 Future<List<ColumnOrSuperColumn>> ret = m_service.submit(task); | |
76 return ret; | |
77 } | |
78 | |
79 public Future<?> batch_mutate(final String _ks,final Map<String,Map<String,List<Mutation>>> _mutation_map,final ConsistencyLevel _level) | |
80 { | |
81 Callable<Boolean> task = new Callable<Boolean>(){ | |
82 @Override | |
83 public Boolean call() throws Exception | |
84 { | |
85 CassandraClientWrapper client = ((CassandraClientThread)Thread.currentThread()).getClientWrapper(); | |
86 client.batch_mutate(_ks,_mutation_map,_level); | |
87 return true; | |
88 } | |
89 }; | |
90 | |
91 Future<?> ret = m_service.submit(task); | |
92 return ret; | |
93 } | |
94 | |
58 public Future<Boolean> insert(final String _ks,final String _key,final ColumnPath _path,final byte[] _value,final long _timestamp,final ConsistencyLevel _level) | 95 public Future<Boolean> insert(final String _ks,final String _key,final ColumnPath _path,final byte[] _value,final long _timestamp,final ConsistencyLevel _level) |
59 { | 96 { |
60 Callable<Boolean> task = new Callable<Boolean>(){ | 97 Callable<Boolean> task = new Callable<Boolean>(){ |
61 @Override | 98 @Override |
62 public Boolean call() throws Exception | 99 public Boolean call() throws Exception |
68 }; | 105 }; |
69 | 106 |
70 Future<Boolean> ret = m_service.submit(task); | 107 Future<Boolean> ret = m_service.submit(task); |
71 return ret; | 108 return ret; |
72 } | 109 } |
110 | |
111 public Future<String> describe_cluster_name() | |
112 { | |
113 Callable<String> task = new Callable<String>(){ | |
114 @Override | |
115 public String call() throws Exception | |
116 { | |
117 return null; | |
118 } | |
119 }; | |
120 | |
121 Future<String> ret = m_service.submit(task); | |
122 return ret; | |
123 } | |
73 } | 124 } |