accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [11/11] git commit: ACCUMULO-1633 merge 1.5.1-SNAPSHOT and add unit test for ACCUMULO-1633
Date Tue, 03 Sep 2013 13:01:45 GMT
ACCUMULO-1633 merge 1.5.1-SNAPSHOT and add unit test for ACCUMULO-1633


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/177fb342
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/177fb342
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/177fb342

Branch: refs/heads/master
Commit: 177fb342067be28812c16a02ff35a469139b7023
Parents: 98ce83a 710c623
Author: Eric Newton <ecn@apache.org>
Authored: Tue Sep 3 09:01:46 2013 -0400
Committer: Eric Newton <ecn@apache.org>
Committed: Tue Sep 3 09:01:46 2013 -0400

----------------------------------------------------------------------
 README                                          |  1 -
 .../client/impl/TabletServerBatchWriter.java    |  2 +-
 .../org/apache/accumulo/test/BatchWriterIT.java | 44 ++++++++++++++++++++
 3 files changed, 45 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/177fb342/README
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/accumulo/blob/177fb342/core/src/main/java/org/apache/accumulo/core/client/impl/TabletServerBatchWriter.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/accumulo/blob/177fb342/test/src/test/java/org/apache/accumulo/test/BatchWriterIT.java
----------------------------------------------------------------------
diff --cc test/src/test/java/org/apache/accumulo/test/BatchWriterIT.java
index 0000000,0000000..a126a9d
new file mode 100644
--- /dev/null
+++ b/test/src/test/java/org/apache/accumulo/test/BatchWriterIT.java
@@@ -1,0 -1,0 +1,44 @@@
++/*
++ * Licensed to the Apache Software Foundation (ASF) under one or more
++ * contributor license agreements.  See the NOTICE file distributed with
++ * this work for additional information regarding copyright ownership.
++ * The ASF licenses this file to You under the Apache License, Version 2.0
++ * (the "License"); you may not use this file except in compliance with
++ * the License.  You may obtain a copy of the License at
++ *
++ *     http://www.apache.org/licenses/LICENSE-2.0
++ *
++ * Unless required by applicable law or agreed to in writing, software
++ * distributed under the License is distributed on an "AS IS" BASIS,
++ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
++ * See the License for the specific language governing permissions and
++ * limitations under the License.
++ */
++package org.apache.accumulo.test;
++
++import org.apache.accumulo.core.client.BatchWriter;
++import org.apache.accumulo.core.client.BatchWriterConfig;
++import org.apache.accumulo.core.client.Connector;
++import org.apache.accumulo.core.data.Mutation;
++import org.apache.accumulo.core.data.Value;
++import org.apache.accumulo.test.functional.ConfigurableMacIT;
++import org.junit.Test;
++
++public class BatchWriterIT extends ConfigurableMacIT {
++  
++  @Test(timeout=30*1000)
++  public void test() throws Exception {
++    // call the batchwriter with buffer of size zero
++    String table = makeTableName();
++    Connector c = getConnector();
++    c.tableOperations().create(table);
++    BatchWriterConfig config = new BatchWriterConfig();
++    config.setMaxMemory(0);
++    BatchWriter writer = c.createBatchWriter(table, config);
++    Mutation m = new Mutation("row");
++    m.put("cf", "cq", new Value("value".getBytes()));
++    writer.addMutation(m);
++    writer.close();
++  }
++
++}


Mime
View raw message