You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by bi...@apache.org on 2011/12/14 21:16:28 UTC
svn commit: r1214442 - in /incubator/accumulo/branches/1.3: ./ docs/
docs/examples/ docs/src/user_manual/chapters/
src/core/src/main/java/org/apache/accumulo/core/client/
src/core/src/main/java/org/apache/accumulo/core/client/impl/
src/core/src/main/ja...
Author: billie
Date: Wed Dec 14 20:16:27 2011
New Revision: 1214442
URL: http://svn.apache.org/viewvc?rev=1214442&view=rev
Log:
ACCUMULO-221 fixed a's
Modified:
incubator/accumulo/branches/1.3/README
incubator/accumulo/branches/1.3/docs/examples/README.dirlist
incubator/accumulo/branches/1.3/docs/examples/README.shard
incubator/accumulo/branches/1.3/docs/isolation.html
incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/analytics.tex
incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/table_configuration.tex
incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/AccumuloSecurityException.java
incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/BatchScanner.java
incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Connector.java
incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/IsolatedScanner.java
incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Scanner.java
incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java
incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerImpl.java
incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormat.java
incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/constraints/AlphaNumKeyConstraint.java
incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java
incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/shard/Reverse.java
incubator/accumulo/branches/1.3/test/system/auto/config.py
incubator/accumulo/branches/1.3/test/system/bench/cloudstone7/cloudstone7.py
Modified: incubator/accumulo/branches/1.3/README
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/README?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/README (original)
+++ incubator/accumulo/branches/1.3/README Wed Dec 14 20:16:27 2011
@@ -86,7 +86,7 @@ to also configure the initial root passw
Start accumulo using the bin/start-all.sh script.
-Use the "bin/accumulo shell -u <username>" command to run a accumulo shell
+Use the "bin/accumulo shell -u <username>" command to run an accumulo shell
interpreter. Within this interpreter, run "createtable <tablename>" to create
a table, and run "table <tablename>" followed by "scan" to scan a table.
Modified: incubator/accumulo/branches/1.3/docs/examples/README.dirlist
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/docs/examples/README.dirlist?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/docs/examples/README.dirlist (original)
+++ incubator/accumulo/branches/1.3/docs/examples/README.dirlist Wed Dec 14 20:16:27 2011
@@ -18,10 +18,10 @@ Notice: Licensed to the Apache Softwa
This example shows how to use Accumulo to store a file system history. It has three classes:
- * Ingest.java - Recursively lists the files and directories under a given path, ingests their names and file info (not the file data!) into a Accumulo table, and indexes the file names in a separate table.
+ * Ingest.java - Recursively lists the files and directories under a given path, ingests their names and file info (not the file data!) into an Accumulo table, and indexes the file names in a separate table.
* QueryUtil.java - Provides utility methods for getting the info for a file, listing the contents of a directory, and performing single wild card searches on file or directory names.
* Viewer.java - Provides a GUI for browsing the file system information stored in Accumulo.
- * FileCountMR.java - Runs MR over the file system information and writes out counts to a Accumulo table.
+ * FileCountMR.java - Runs MR over the file system information and writes out counts to an Accumulo table.
* FileCount.java - Accomplishes the same thing as FileCountMR, but in a different way. Computes recursive counts and stores them back into table.
* StringArraySummation.java - Aggregates counts for the FileCountMR reducer.
Modified: incubator/accumulo/branches/1.3/docs/examples/README.shard
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/docs/examples/README.shard?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/docs/examples/README.shard (original)
+++ incubator/accumulo/branches/1.3/docs/examples/README.shard Wed Dec 14 20:16:27 2011
@@ -19,7 +19,7 @@ Notice: Licensed to the Apache Softwa
Accumulo has in iterator called the intersecting iterator which supports querying a term index that is partitioned by
document, or "sharded". This example shows how to use the intersecting iterator through these four programs:
- * Index.java - Indexes a set of text files into a Accumulo table
+ * Index.java - Indexes a set of text files into an Accumulo table
* Query.java - Finds documents containing a given set of terms.
* Reverse.java - Reads the index table and writes a map of documents to terms into another table.
* ContinuousQuery.java Uses the table populated by Reverse.java to select N random terms per document. Then it continuously and randomly queries those terms.
Modified: incubator/accumulo/branches/1.3/docs/isolation.html
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/docs/isolation.html?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/docs/isolation.html (original)
+++ incubator/accumulo/branches/1.3/docs/isolation.html Wed Dec 14 20:16:27 2011
@@ -31,7 +31,7 @@
<li>iterators executed as part of a minor or major compaction
<li>bulk import of new files
</ul>
-Isolation garuantees that either all or none of the changes made by these operations on a row are seen. Use the <a href='apidocs/org/apache/accumulo/core/client/IsolatedScanner.html'>IsolatedScanner</a> to obtain an isolated view of a accumulo table. When using the regular scanner it is possible to see a non isolated view of a row. For example if a mutation modifies three columns, it is possible that you will only see two of those modifications. With the isolated scanner either all three of the changes are seen or none. For an example of this try running the <a href='apidocs/org/apache/accumulo/examples/isolation/InterferenceTest.html'>InterferenceTest</a> example.
+Isolation guarantees that either all or none of the changes made by these operations on a row are seen. Use the <a href='apidocs/org/apache/accumulo/core/client/IsolatedScanner.html'>IsolatedScanner</a> to obtain an isolated view of an accumulo table. When using the regular scanner it is possible to see a non isolated view of a row. For example if a mutation modifies three columns, it is possible that you will only see two of those modifications. With the isolated scanner either all three of the changes are seen or none. For an example of this try running the <a href='apidocs/org/apache/accumulo/examples/isolation/InterferenceTest.html'>InterferenceTest</a> example.
<p>At this time there is no client side isolation support for the <a href='apidocs/org/apache/accumulo/core/client/BatchScanner.html'>BatchScanner</a>. You may consider using the <a href='apidocs/org/apache/accumulo/core/iterators/WholeRowIterator.html'>WholeRowIterator</a> with the <a href='apidocs/org/apache/accumulo/core/client/BatchScanner.html'>BatchScanner</a> to achieve isolation though. This drawback of doing this is that entire rows are read into memory on the server side. If a row is too big, it may crash a tablet server. The <a href='apidocs/org/apache/accumulo/core/client/IsolatedScanner.html'>IsolatedScanner</a> buffers rows on the client side so a large row will not crash a tablet server.
Modified: incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/analytics.tex
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/analytics.tex?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/analytics.tex (original)
+++ incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/analytics.tex Wed Dec 14 20:16:27 2011
@@ -23,7 +23,7 @@ MapReduce and Iterators in conjunction w
\section{MapReduce}
Accumulo tables can be used as the source and destination of MapReduce jobs. To
-use a Accumulo table with a MapReduce job (specifically with the new Hadoop API
+use an Accumulo table with a MapReduce job (specifically with the new Hadoop API
as of version 0.20), configure the job parameters to use the AccumuloInputFormat
and AccumuloOutputFormat. Accumulo specific parameters can be set via these
two format classes to do the following:
@@ -35,7 +35,7 @@ two format classes to do the following:
\subsection{Mapper and Reducer classes}
-To read from a Accumulo table create a Mapper with the following class
+To read from an Accumulo table create a Mapper with the following class
parameterization and be sure to configure the AccumuloInputFormat.
\small
@@ -48,7 +48,7 @@ class MyMapper extends Mapper<Key,Value,
\end{verbatim}
\normalsize
-To write to a Accumulo table, create a Reducer with the following class
+To write to an Accumulo table, create a Reducer with the following class
parameterization and be sure to configure the AccumuloOutputFormat. The key
emitted from the Reducer identifies the table to which the mutation is sent. This
allows a single Reducer to write to more than one table if desired. A default table
@@ -174,18 +174,18 @@ values in the aggregation such as when c
\subsection{Feature Vectors}
-An interesting use of aggregating iterators within a Accumulo table is to store
+An interesting use of aggregating iterators within an Accumulo table is to store
feature vectors for use in machine learning algorithms. For example, many
algorithms such as k-means clustering, support vector machines, anomaly detection,
etc. use the concept of a feature vector and the calculation of distance metrics to
-learn a particular model. The columns in a Accumulo table can be used to efficiently
+learn a particular model. The columns in an Accumulo table can be used to efficiently
store sparse features and their weights to be incrementally updated via the use of an
aggregating iterator.
\section{Statistical Modeling}
Statistical models that need to be updated by many machines in parallel could be
-similarly stored within a Accumulo table. For example, a MapReduce job that is
+similarly stored within an Accumulo table. For example, a MapReduce job that is
iteratively updating a global statistical model could have each map or reduce worker
reference the parts of the model to be read and updated through an embedded
Accumulo client.
Modified: incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/table_configuration.tex
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/table_configuration.tex?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/table_configuration.tex (original)
+++ incubator/accumulo/branches/1.3/docs/src/user_manual/chapters/table_configuration.tex Wed Dec 14 20:16:27 2011
@@ -122,7 +122,7 @@ An example of constraints can be found i
\texttt{accumulo/src/examples/main/java/accumulo/examples/constraints} .
\section{Bloom Filters}
-As mutations are applied to a Accumulo table, several files are created per tablet. If
+As mutations are applied to an Accumulo table, several files are created per tablet. If
bloom filters are enabled, Accumulo will create and load a small data structure into
memory to determine whether a file contains a given key before opening the file.
This can speed up lookups considerably.
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/AccumuloSecurityException.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/AccumuloSecurityException.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/AccumuloSecurityException.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/AccumuloSecurityException.java Wed Dec 14 20:16:27 2011
@@ -20,7 +20,7 @@ import org.apache.accumulo.core.security
import org.apache.accumulo.core.security.thrift.ThriftSecurityException;
/**
- * A Accumulo Exception for security violations, authentication failures, authorization failures, etc.
+ * An Accumulo Exception for security violations, authentication failures, authorization failures, etc.
*
*/
public class AccumuloSecurityException extends Exception {
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/BatchScanner.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/BatchScanner.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/BatchScanner.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/BatchScanner.java Wed Dec 14 20:16:27 2011
@@ -45,7 +45,7 @@ public interface BatchScanner extends Sc
void setRanges(Collection<Range> ranges);
/**
- * Returns an iterator over a accumulo table. This iterator uses the options that are currently set for its lifetime. So setting options will have no effect
+ * Returns an iterator over an accumulo table. This iterator uses the options that are currently set for its lifetime. So setting options will have no effect
* on existing iterators.
*
* Keys returned by the iterator are not guaranteed to be in sorted order.
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Connector.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Connector.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Connector.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Connector.java Wed Dec 14 20:16:27 2011
@@ -22,7 +22,7 @@ import org.apache.accumulo.core.client.a
import org.apache.accumulo.core.security.Authorizations;
/**
- * Connector facilitates connecting to a Accumulo instance. One of the main purposes of this class is to make it easy to connect to multiple Accumulo instances
+ * Connector facilitates connecting to an Accumulo instance. One of the main purposes of this class is to make it easy to connect to multiple Accumulo instances
* within the same JVM.
*
* Additionally, the Connector object enforces security on the client side, by forcing all API calls to be accompanied by user credentials.
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/IsolatedScanner.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/IsolatedScanner.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/IsolatedScanner.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/IsolatedScanner.java Wed Dec 14 20:16:27 2011
@@ -32,7 +32,7 @@ import org.apache.accumulo.core.util.Uti
import org.apache.hadoop.io.Text;
/**
- * A scanner that presents a row isolated view of a accumulo table. Rows are buffered in memory on the client side. If you think your rows may not fit into
+ * A scanner that presents a row isolated view of an accumulo table. Rows are buffered in memory on the client side. If you think your rows may not fit into
* memory, then you can provide an alternative row buffer factory to the constructor. This would allow rows to be buffered to disk for example.
*
*/
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Scanner.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Scanner.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Scanner.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/Scanner.java Wed Dec 14 20:16:27 2011
@@ -74,7 +74,7 @@ public interface Scanner extends Scanner
void disableIsolation();
/**
- * Returns an iterator over a accumulo table. This iterator uses the options that are currently set on the scanner for its lifetime. So setting options on a
+ * Returns an iterator over an accumulo table. This iterator uses the options that are currently set on the scanner for its lifetime. So setting options on a
* Scanner object will have no effect on existing iterators.
*
* Keys are returned in sorted order by the iterator.
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/ZooKeeperInstance.java Wed Dec 14 20:16:27 2011
@@ -43,9 +43,9 @@ import org.apache.log4j.Logger;
* The advantage of using zookeeper to obtain information about accumulo is that zookeeper is highly available, very responsive, and supports caching.
*
* <p>
- * Because it is possible for multiple instances of accumulo to share a single set of zookeeper servers, all constructors require a accumulo instance name.
+ * Because it is possible for multiple instances of accumulo to share a single set of zookeeper servers, all constructors require an accumulo instance name.
*
- * If you do not know the instance names then run accumulo org.apache.accumulo.server.util.ListInstances on a accumulo server.
+ * If you do not know the instance names then run accumulo org.apache.accumulo.server.util.ListInstances on an accumulo server.
*
*/
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerImpl.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerImpl.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerImpl.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/impl/ScannerImpl.java Wed Dec 14 20:16:27 2011
@@ -112,7 +112,7 @@ public class ScannerImpl extends Scanner
}
/**
- * Returns an iterator over a accumulo table. This iterator uses the options that are currently set on the scanner for its lifetime. So setting options on a
+ * Returns an iterator over an accumulo table. This iterator uses the options that are currently set on the scanner for its lifetime. So setting options on a
* Scanner object will have no effect on existing iterators.
*/
public synchronized Iterator<Entry<Key,Value>> iterator() {
Modified: incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormat.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormat.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormat.java (original)
+++ incubator/accumulo/branches/1.3/src/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AccumuloInputFormat.java Wed Dec 14 20:16:27 2011
@@ -120,7 +120,7 @@ public class AccumuloInputFormat extends
private static final String ISOLATED = PREFIX + ".isolated";
- // Used to specify the maximum # of versions of a Accumulo cell value to return
+ // Used to specify the maximum # of versions of an Accumulo cell value to return
private static final String MAX_VERSIONS = PREFIX + ".maxVersions";
// Used for specifying the iterators to be applied
@@ -265,7 +265,7 @@ public class AccumuloInputFormat extends
}
/**
- * Specify a Accumulo iterator type to manage the behavior of the underlying table scan this InputFormat's Record Reader will conduct, w/ priority dictating
+ * Specify an Accumulo iterator type to manage the behavior of the underlying table scan this InputFormat's Record Reader will conduct, w/ priority dictating
* the order in which specified iterators are applied. Repeat calls to specify multiple iterators are allowed.
*
* @param job
@@ -700,7 +700,7 @@ public class AccumuloInputFormat extends
}
/**
- * The Class RangeInputSplit. Encapsulates a Accumulo range for use in Map Reduce jobs.
+ * The Class RangeInputSplit. Encapsulates an Accumulo range for use in Map Reduce jobs.
*/
public static class RangeInputSplit extends InputSplit implements Writable {
private Range range;
@@ -843,7 +843,7 @@ public class AccumuloInputFormat extends
}
/**
- * The Class AccumuloIteratorOption. Encapsulates specifics for a Accumulo iterator's optional configuration details - associated via the iteratorName.
+ * The Class AccumuloIteratorOption. Encapsulates specifics for an Accumulo iterator's optional configuration details - associated via the iteratorName.
*/
static class AccumuloIteratorOption {
private static final String FIELD_SEP = ":";
Modified: incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/constraints/AlphaNumKeyConstraint.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/constraints/AlphaNumKeyConstraint.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/constraints/AlphaNumKeyConstraint.java (original)
+++ incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/constraints/AlphaNumKeyConstraint.java Wed Dec 14 20:16:27 2011
@@ -25,7 +25,7 @@ import org.apache.accumulo.core.data.Col
import org.apache.accumulo.core.data.Mutation;
/**
- * This class is a accumulo constraint that ensures all fields of a key are alpha numeric.
+ * This class is an accumulo constraint that ensures all fields of a key are alpha numeric.
*
*
*
Modified: incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java (original)
+++ incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/mapreduce/bulk/BulkIngestExample.java Wed Dec 14 20:16:27 2011
@@ -45,7 +45,7 @@ import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;
/**
- * Example map reduce job that bulk ingest data into a accumulo table. The expected input is text files containing tab separated key value pairs on each line.
+ * Example map reduce job that bulk ingest data into an accumulo table. The expected input is text files containing tab separated key value pairs on each line.
*/
public class BulkIngestExample extends Configured implements Tool {
public static class MapClass extends Mapper<LongWritable,Text,Text,Text> {
Modified: incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/shard/Reverse.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/shard/Reverse.java?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/shard/Reverse.java (original)
+++ incubator/accumulo/branches/1.3/src/examples/src/main/java/org/apache/accumulo/examples/shard/Reverse.java Wed Dec 14 20:16:27 2011
@@ -29,7 +29,7 @@ import org.apache.accumulo.core.data.Val
import org.apache.hadoop.io.Text;
/**
- * The program reads a accumulo table written by Index.java and writes out to another table. It writes out a mapping of documents to terms. The document to term
+ * The program reads an accumulo table written by Index.java and writes out to another table. It writes out a mapping of documents to terms. The document to term
* mapping is used by ContinuousQuery.java
*
*/
Modified: incubator/accumulo/branches/1.3/test/system/auto/config.py
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/test/system/auto/config.py?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/test/system/auto/config.py (original)
+++ incubator/accumulo/branches/1.3/test/system/auto/config.py Wed Dec 14 20:16:27 2011
@@ -18,7 +18,7 @@
from xml.sax import make_parser, handler
def parse(filename):
- 'Read a accumulo config file and return it as a dictionary string -> string'
+ 'Read an accumulo config file and return it as a dictionary string -> string'
result = {}
class Handler(handler.ContentHandler):
name = None
Modified: incubator/accumulo/branches/1.3/test/system/bench/cloudstone7/cloudstone7.py
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.3/test/system/bench/cloudstone7/cloudstone7.py?rev=1214442&r1=1214441&r2=1214442&view=diff
==============================================================================
--- incubator/accumulo/branches/1.3/test/system/bench/cloudstone7/cloudstone7.py (original)
+++ incubator/accumulo/branches/1.3/test/system/bench/cloudstone7/cloudstone7.py Wed Dec 14 20:16:27 2011
@@ -20,7 +20,7 @@ from lib import cloudshell
from lib.RowHashBenchmark import RowHashBenchmark
class CloudStone7(RowHashBenchmark):
- "Hashes all the rows in a accumulo table and outputs them to another table"
+ "Hashes all the rows in an accumulo table and outputs them to another table"
def suite():
result = unittest.TestSuite([