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([
