You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2011/11/02 15:17:09 UTC
svn commit: r1196593 -
/incubator/accumulo/trunk/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/Ingest.java
Author: ecn
Date: Wed Nov 2 14:17:08 2011
New Revision: 1196593
URL: http://svn.apache.org/viewvc?rev=1196593&view=rev
Log:
ACCUMULO-86: merge 1.3 documentation and examples changes to trunk
Modified:
incubator/accumulo/trunk/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/Ingest.java
Modified: incubator/accumulo/trunk/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/Ingest.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/trunk/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/Ingest.java?rev=1196593&r1=1196592&r2=1196593&view=diff
==============================================================================
--- incubator/accumulo/trunk/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/Ingest.java (original)
+++ incubator/accumulo/trunk/src/examples/src/main/java/org/apache/accumulo/examples/dirlist/Ingest.java Wed Nov 2 14:17:08 2011
@@ -126,6 +126,7 @@ public class Ingest {
String dataTable = args[6];
byte[] visibility = args[7].getBytes();
ColumnVisibility colvis = new ColumnVisibility(args[7]);
+ int chunkSize = Integer.parseInt(args[8]);
Connector conn = new ZooKeeperInstance(instance, zooKeepers).getConnector(user, pass.getBytes());
if (!conn.tableOperations().exists(nameTable))