src/main/java/org/apache/accumulo/testing/stress/Write.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.accumulo.testing.stress;

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.TableExistsException;
import org.apache.accumulo.core.client.TableNotFoundException;

public class Write {

  public static void main(String[] args) throws Exception {
    WriteOptions opts = new WriteOptions();
    opts.parseArgs(Write.class.getName(), args);

    opts.check();

    try (AccumuloClient c = Accumulo.newClient().from(opts.getClientProps()).build()) {

      if (opts.clear_table && c.tableOperations().exists(opts.tableName)) {
        try {
          c.tableOperations().delete(opts.tableName);
        } catch (TableNotFoundException e) {
          System.err.println("Couldn't delete the table because it doesn't exist any more.");
        }
      }

      if (!c.tableOperations().exists(opts.tableName)) {
        try {
          c.tableOperations().create(opts.tableName);
        } catch (TableExistsException e) {
          System.err.println("Couldn't create table ourselves, but that's ok. Continuing.");
        }
      }

      long writeDelay = opts.write_delay;
      if (writeDelay < 0) {
        writeDelay = 0;
      }

      RandomMutations mutations = new RandomMutations(
          // rows
          new RandomByteArrays(new RandomWithinRange(opts.row_seed, opts.rowMin(), opts.rowMax())),
          // cfs
          new RandomByteArrays(new RandomWithinRange(opts.cf_seed, opts.cfMin(), opts.cfMax())),
          // cqs
          new RandomByteArrays(new RandomWithinRange(opts.cq_seed, opts.cqMin(), opts.cqMax())),
          // vals
          new RandomByteArrays(
              new RandomWithinRange(opts.value_seed, opts.valueMin(), opts.valueMax())),
          // number of cells per row
          new RandomWithinRange(opts.row_width_seed, opts.rowWidthMin(), opts.rowWidthMax()),
          // max cells per mutation
          opts.max_cells_per_mutation);

      try (BatchWriter batchWriter = c.createBatchWriter(opts.tableName);
          DataWriter dw = DataWriter.create(batchWriter, mutations)) {
        while (true) {
          dw.next();
          if (writeDelay > 0) {
            Thread.sleep(writeDelay);
          }
        }
      }
    }
  }
}