| package tour; |
| |
| // Classes you will use along the tour |
| import java.util.Map; |
| import java.util.Map.Entry; |
| import java.util.Properties; |
| import java.util.Random; |
| import java.util.List; |
| import java.util.ArrayList; |
| import java.util.concurrent.CompletableFuture; |
| import java.util.concurrent.Future; |
| import java.util.function.Function; |
| |
| import org.apache.accumulo.core.client.Accumulo; |
| import org.apache.accumulo.core.client.AccumuloClient; |
| 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.client.Scanner; |
| import org.apache.accumulo.core.client.TableNotFoundException; |
| import org.apache.accumulo.core.client.IsolatedScanner; |
| import org.apache.accumulo.core.client.BatchScanner; |
| import org.apache.accumulo.core.client.ConditionalWriter; |
| import org.apache.accumulo.core.client.ConditionalWriter.Status; |
| import org.apache.accumulo.core.client.ConditionalWriterConfig; |
| import org.apache.accumulo.core.client.security.tokens.PasswordToken; |
| import org.apache.accumulo.core.data.Key; |
| import org.apache.accumulo.core.data.Range; |
| import org.apache.accumulo.core.data.Mutation; |
| import org.apache.accumulo.core.data.Value; |
| import org.apache.accumulo.core.data.Condition; |
| import org.apache.accumulo.core.data.ConditionalMutation; |
| import org.apache.accumulo.core.security.Authorizations; |
| import org.apache.accumulo.core.security.TablePermission; |
| import org.apache.accumulo.core.security.ColumnVisibility; |
| import org.apache.accumulo.minicluster.MiniAccumuloCluster; |
| import org.apache.hadoop.io.Text; |
| import java.nio.file.Files; |
| import java.nio.file.Path; |
| import java.nio.file.Paths; |
| |
| |
| public class Main { |
| |
| public static void main(String[] args) throws Exception { |
| System.out.println("Running the Accumulo tour. Having fun yet?"); |
| |
| Path tempDir = Files.createTempDirectory(Paths.get("target"), "mac"); |
| MiniAccumuloCluster mac = new MiniAccumuloCluster(tempDir.toFile(), "tourpass"); |
| Properties properties = mac.getClientProperties(); |
| |
| mac.start(); |
| |
| try (AccumuloClient client = Accumulo.newClient().from(properties).build()) { |
| exercise(client); |
| } |
| mac.stop(); |
| } |
| |
| static void exercise(AccumuloClient client) throws Exception{ |
| // start writing your code here |
| |
| } |
| } |