List of addMutation() Examples

Examples of addMutation()

org.apache.accumulo.core.client.BatchWriter.addMutation()
Queues one mutation to write. @param m the mutation to add @throws MutationsRejectedException this could be thrown because current or previous mutations failed
org.apache.accumulo.core.client.impl.BatchWriterImpl.addMutation()
org.apache.accumulo.core.client.impl.TabletLocator.TabletServerMutations.addMutation()
org.apache.hadoop.hbase.quotas.OperationQuota.addMutation()
Add a mutation result. This will be used to calculate the exact quota and have a better mutation average size for the next time.

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()

    for (Entry<Key,Value> entry : scanner) {
      Key key = entry.getKey();
      Mutation m = new Mutation(key.getRow());
      m.put(key.getColumnFamily().toString(), key.getColumnQualifier().toString(), key.getTimestamp() + 1, "v" + (count));
      count++;
      bw.addMutation(m);
    }
    
    bw.flush();
    
    count = 10;

View Full Code Here

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()

    c.tableOperations().create("b");
    MultiTableBatchWriter bw = c.createMultiTableBatchWriter(new BatchWriterConfig());
    Mutation m1 = new Mutation("r1");
    m1.put("cf1", "cq1", 1, "v1");
    BatchWriter b = bw.getBatchWriter("a");
    b.addMutation(m1);
    b.flush();
    b = bw.getBatchWriter("b");
    b.addMutation(m1);
    b.flush();

View Full Code Here

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()

    m1.put("cf1", "cq1", 1, "v1");
    BatchWriter b = bw.getBatchWriter("a");
    b.addMutation(m1);
    b.flush();
    b = bw.getBatchWriter("b");
    b.addMutation(m1);
    b.flush();
    
    Scanner scanner = c.createScanner("a", Constants.NO_AUTHS);
    int count = 0;
    for (@SuppressWarnings("unused")

View Full Code Here

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()

    BatchWriter bw = c.createBatchWriter("test", new BatchWriterConfig());
    
    for (int i = 0; i < 10; i++) {
      Mutation m = new Mutation("r1");
      m.put("cf1", "cq1", "" + i);
      bw.addMutation(m);
    }
    
    bw.close();
    
    Scanner scanner = c.createScanner("test", Constants.NO_AUTHS);

View Full Code Here

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()

         */
        if (null == writer) {
          log.warn("writer is not ready; discarding span.");
          return;
        }
        writer.addMutation(spanMutation);
        writer.addMutation(indexMutation);
        if (timeMutation != null)
          writer.addMutation(timeMutation);
      } catch (MutationsRejectedException exception) {
        log.warn("Unable to write mutation to table; discarding span. set log level to DEBUG for span information and stacktrace. cause: " + exception);

View Full Code Here

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()

        if (null == writer) {
          log.warn("writer is not ready; discarding span.");
          return;
        }
        writer.addMutation(spanMutation);
        writer.addMutation(indexMutation);
        if (timeMutation != null)
          writer.addMutation(timeMutation);
      } catch (MutationsRejectedException exception) {
        log.warn("Unable to write mutation to table; discarding span. set log level to DEBUG for span information and stacktrace. cause: " + exception);
        if (log.isDebugEnabled()) {

View Full Code Here

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()

          return;
        }
        writer.addMutation(spanMutation);
        writer.addMutation(indexMutation);
        if (timeMutation != null)
          writer.addMutation(timeMutation);
      } catch (MutationsRejectedException exception) {
        log.warn("Unable to write mutation to table; discarding span. set log level to DEBUG for span information and stacktrace. cause: " + exception);
        if (log.isDebugEnabled()) {
          log.debug("discarded span due to rejection of mutation: " + spanMutation, exception);
        }

View Full Code Here

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()


    conn.tableOperations().create("table1");
    BatchWriter bw = conn.createBatchWriter("table1", new BatchWriterConfig());


    for (Mutation m : createMutations()) {
      bw.addMutation(m);
    }
    IteratorSetting is = new IteratorSetting(40, SummingRowFilter.class);
    conn.tableOperations().attachIterator("table1", is);


    Scanner scanner = conn.createScanner("table1", Constants.NO_AUTHS);

View Full Code Here

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()

    Connector conn = instance.getConnector("", new PasswordToken(""));


    conn.tableOperations().create("chained_row_filters");
    BatchWriter bw = conn.createBatchWriter("chained_row_filters", new BatchWriterConfig());
    for (Mutation m : createMutations()) {
      bw.addMutation(m);
    }
    conn.tableOperations().attachIterator("chained_row_filters", new IteratorSetting(40, "trueFilter1", TrueFilter.class));
    conn.tableOperations().attachIterator("chained_row_filters", new IteratorSetting(41, "trueFilter2", TrueFilter.class));
    Scanner scanner = conn.createScanner("chained_row_filters", Constants.NO_AUTHS);
    assertEquals(new HashSet<String>(Arrays.asList("0", "1", "2", "3", "4")), getRows(scanner));

View Full Code Here

Examples of org.apache.accumulo.core.client.BatchWriter.addMutation()

    Connector conn = instance.getConnector("", new PasswordToken(""));


    conn.tableOperations().create("filter_conjunction");
    BatchWriter bw = conn.createBatchWriter("filter_conjunction", new BatchWriterConfig());
    for (Mutation m : createMutations()) {
      bw.addMutation(m);
    }
    conn.tableOperations().attachIterator("filter_conjunction", new IteratorSetting(40, "rowZeroOrOne", RowZeroOrOneFilter.class));
    conn.tableOperations().attachIterator("filter_conjunction", new IteratorSetting(41, "rowOneOrTwo", RowOneOrTwoFilter.class));
    Scanner scanner = conn.createScanner("filter_conjunction", Constants.NO_AUTHS);
    assertEquals(new HashSet<String>(Arrays.asList("1")), getRows(scanner));

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.