MCPcopy Create free account
hub / github.com/OpenTSDB/asynchbase / add

Method add

test/TestMultiAction.java:147–179  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

145 }
146
147 @Test
148 public void add() throws Exception {
149 PutRequest put1 = new PutRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE);
150 put1.region = region;
151 PutRequest put2 = new PutRequest(TABLE, KEY, FAMILY, "myqual".getBytes(), VALUE);
152 put2.region = region;
153 DeleteRequest delete = new DeleteRequest(TABLE, KEY, FAMILY, QUALIFIER);
154 delete.region = region;
155 AppendRequest append = new AppendRequest(TABLE, KEY, FAMILY, QUALIFIER, VALUE);
156 append.region = region;
157
158 // same type, different qualifiers
159 MultiAction multi = new MultiAction();
160 assertEquals(0, multi.size()); // make sure it's empty
161
162 multi.add(put1);
163 multi.add(put2);
164 assertEquals(2, multi.size());
165
166 // all kinds of types
167 multi = new MultiAction();
168 multi.add(put1);
169 multi.add(put2);
170 multi.add(delete);
171 multi.add(append);
172 assertEquals(4, multi.size());
173
174 // double up on the same RPC as this is allowed
175 multi = new MultiAction();
176 multi.add(put1);
177 multi.add(put1);
178 assertEquals(2, multi.size());
179 }
180
181 @Test
182 public void addErrors() throws Exception {

Calls 2

sizeMethod · 0.95
addMethod · 0.95

Tested by

no test coverage detected