Skip to content

Updating commands in spark, reservations, terasort, and uniquecols examples #138

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
Amemeda wants to merge 3 commits into
base: main
Choose a base branch
from
+19 −18
Open

Updating commands in spark, reservations, terasort, and uniquecols examples #138

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
b4b8978
Updating commands in spark, reservations, terasort, and uniquecols
Amemeda Jun 10, 2026
111affb
Merge branch 'main' of github.com:Amemeda/accumulo-examples into fina…
Amemeda Jul 10, 2026
e4a2488
updating imports for erroring ITs
Amemeda Jul 10, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions docs/reservations.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,14 +25,14 @@ and trent to reserve room06 on 20140101. Bob ends up getting the reservation
and everyone else is put on a wait list. The example code will take any string
for what, when and who.

$ /path/to/accumulo org.apache.accumulo.server.util.ListInstances
$ accumulo inst list-instances

Instance Name | Instance ID | Master
---------------------+--------------------------------------+-------------------------------
<instance name> | 9f8f2a97-432f-4e66-b153-861e2a1ca246 | localhost:9999

$ /path/to/accumulo shell -u root -p secret -e "createnamespace examples"
$ /path/to/accumulo shell -u root -p secret -e "createtable examples.ars"
$ accumulo shell --user root --password secret --execute-command "createnamespace examples"
$ accumulo shell --user root --password secret --execute-command "createtable examples.ars"
Comment on lines +34 to +35

@ctubbsii ctubbsii Jul 10, 2026

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We can drop the user and password options, as the user can specify these in a client config file, and that's not what this example is trying to teach, so it's fine to omit them. I would not expand the execute-command, as it's much more common for people to use the single letter version.

$ ./bin/runex reservations.ARS
>connect <instance name> localhost root secret examples.ars
connected
Expand Down
2 changes: 1 addition & 1 deletion docs/terasort.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ hadoop terasort benchmark.
First, make sure the 'examples' namespace exists. If it already exists, the error message can be
ignored.

$ accumulo shell -u root -p secret -e 'createnamespace examples'
$ accumulo shell --user root --password secret --execute-command 'createnamespace examples'

This example is run with arguments describing the amount of data:

Expand Down
20 changes: 10 additions & 10 deletions docs/uniquecols.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ Create a table and add rows that all have identical column family and column
qualifiers.

```
$ /path/to/accumulo shell -u username -p secret
$ accumulo shell --user root --password secret
username@instance> createnamespace examples
username@instance> createtable examples.unique
username@instance examples.unique> insert row1 fam1 qual1 v1
Expand Down Expand Up @@ -58,15 +58,15 @@ will be spread among various `part-r-xxxxx` files.
Go back to the shell and add some additional entries.

```text
$ /path/to/accumulo shell -u username -p secret
username@instance> table unique
username@instance example.unique> insert row1 fam2 qual2 v2
username@instance example.unique> insert row1 fam3 qual2 v2
username@instance example.unique> insert row1 fam2 qual2 v2
username@instance example.unique> insert row2 fam2 qual2 v2
username@instance example.unique> insert row3 fam2 qual2 v2
username@instance example.unique> insert row3 fam3 qual3 v2
username@instance example.unique> insert row3 fam3 qual4 v2
$ accumulo shell --user root --password secret
username@instance> table examples.unique
username@instance examples.unique> insert row1 fam2 qual2 v2
username@instance examples.unique> insert row1 fam3 qual2 v2
username@instance examples.unique> insert row1 fam2 qual2 v2
username@instance examples.unique> insert row2 fam2 qual2 v2
username@instance examples.unique> insert row3 fam2 qual2 v2
username@instance examples.unique> insert row3 fam3 qual3 v2
username@instance examples.unique> insert row3 fam3 qual4 v2
```

Re-running the command will now find any additional unique column values.
Expand Down
5 changes: 3 additions & 2 deletions spark/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,9 +36,10 @@ a Spark application that does following:
bulk import to Accumulo table
2. **Batchwriter** - Creates a `BatchWriter` in Spark code to write to the table.

This application can be run using the command:
This application can be run using the following commands:

./run.sh batch /path/to/accumulo-client.properties
$ cd /path/to/accumulo-examples/spark
$ ./run.sh batch /path/to/accumulo-client.properties
Comment on lines +39 to +42

@ctubbsii ctubbsii Jul 10, 2026

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This README is already in the directory, so the cd is implied. This part doesn't really need to change, does it?


Change `batch` to `bulk` to use Bulk import method.

Expand Down
2 changes: 1 addition & 1 deletion src/test/java/org/apache/accumulo/examples/ExamplesIT.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -70,11 +70,11 @@
import org.apache.accumulo.examples.shard.Index;
import org.apache.accumulo.examples.shard.Query;
import org.apache.accumulo.examples.shard.Reverse;
import org.apache.accumulo.harness.AccumuloClusterHarness;
import org.apache.accumulo.minicluster.MemoryUnit;
import org.apache.accumulo.miniclusterImpl.MiniAccumuloConfigImpl;
import org.apache.accumulo.test.TestIngest;
import org.apache.accumulo.test.TestIngest.IngestParams;
import org.apache.accumulo.test.harness.AccumuloClusterHarness;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
Expand Down
2 changes: 1 addition & 1 deletion src/test/java/org/apache/accumulo/examples/filedata/ChunkInputStreamIT.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,8 +41,8 @@
import org.apache.accumulo.core.data.Value;
import org.apache.accumulo.core.security.Authorizations;
import org.apache.accumulo.core.security.ColumnVisibility;
import org.apache.accumulo.harness.AccumuloClusterHarness;
import org.apache.accumulo.miniclusterImpl.MiniAccumuloConfigImpl;
import org.apache.accumulo.test.harness.AccumuloClusterHarness;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.Text;
import org.junit.jupiter.api.AfterEach;
Expand Down
Loading