Examples of addMutation()

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

61
62
63
64
65
66
67
68
69
70
71
      while (iter.hasNext()) {
        Entry<Key,Value> next = iter.next();
        Key k = next.getKey();
        Mutation m = new Mutation(k.getRow());
        m.putDelete(k.getColumnFamily(), k.getColumnQualifier(), new ColumnVisibility(k.getColumnVisibility()), k.getTimestamp());
        writer.addMutation(m);
      }
    } finally {
      writer.close();
    }
  }
View Full Code Here

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

119
120
121
122
123
124
125
126
127
128
129
      r.nextBytes(rowData);
      TestIngest.toPrintableChars(rowData);
     
      Mutation mut = new Mutation(new Text(rowData));
      mut.put(new Text(""), new Text(""), new Value(Integer.toString(i).getBytes(Constants.UTF8)));
      bw.addMutation(mut);
    }
   
    bw.close();
   
    checkSplits(table, expectedSplits, expectedSplits);
View Full Code Here

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

41
42
43
44
45
46
47
48
    }
    state.set("totalWrites", totalWrites);
   
    Mutation m = new Mutation(new Text(String.format("%010d", totalWrites)));
    m.put(new Text("cf"), new Text("cq"), new Value("val".getBytes(Constants.UTF8)));
    bw.addMutation(m);
  }
}
View Full Code Here

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

55
56
57
58
59
60
61
62
63
64
65
    BatchWriter bw = getConnector().createBatchWriter("test", new BatchWriterConfig());

    Mutation m1 = new Mutation("r1");
    m1.put("cf1", "cq1", 1, "5");

    bw.addMutation(m1);

    bw.flush();

    Scanner scanner = getConnector().createScanner("test", new Authorizations());
View Full Code Here

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

84
85
86
87
88
89
90
91
92
93
94
    Mutation m2 = new Mutation("r2");
    m2.put("cf1", "cq1", 1, "6");

    try {
      bw.addMutation(m1);
      bw.flush();
      throw new Exception("batch writer did not fail");
    } catch (Exception e) {

    }
View Full Code Here

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

55
56
57
58
59
60
61
62
63
64
65
          long val = (rand.nextLong() & 0x7fffffffffffffffl);
          for (int j = 0; j < 10; j++) {
            m.put("cf", "cq" + j, new Value(String.format("%016x", val).getBytes(Constants.UTF8)));
          }
         
          bw.addMutation(m);
        }
      } finally {
        bw.close();
      }
     
View Full Code Here

Examples of org.apache.accumulo.core.client.impl.BatchWriterImpl.addMutation()

651
652
653
654
655
656
657
658
659
660
661
        if (key.getColumnFamily().equals(Constants.METADATA_DATAFILE_COLUMN_FAMILY)) {
          String relPath = key.getColumnQualifier().toString();
          // only insert deletes for files owned by this table
          if (!relPath.startsWith("../"))
            bw.addMutation(createDeleteMutation(tableId, relPath));
        }

        if (Constants.METADATA_DIRECTORY_COLUMN.hasColumns(key)) {
          bw.addMutation(createDeleteMutation(tableId, cell.getValue().toString()));
        }
View Full Code Here

Examples of org.apache.accumulo.core.client.impl.BatchWriterImpl.addMutation()

655
656
657
658
659
660
661
662
663
664
665
          if (!relPath.startsWith("../"))
            bw.addMutation(createDeleteMutation(tableId, relPath));
        }

        if (Constants.METADATA_DIRECTORY_COLUMN.hasColumns(key)) {
          bw.addMutation(createDeleteMutation(tableId, cell.getValue().toString()));
        }
      }

      bw.flush();
View Full Code Here

Examples of org.apache.accumulo.core.client.impl.BatchWriterImpl.addMutation()

674
675
676
677
678
679
680
681
682
683
684
        if (lock != null)
          putLockID(lock, m);
      }

      if (key.getRow().compareTo(m.getRow(), 0, m.getRow().length) != 0) {
        bw.addMutation(m);
        m = new Mutation(key.getRow());
        if (lock != null)
          putLockID(lock, m);
      }
      m.putDelete(key.getColumnFamily(), key.getColumnQualifier());
View Full Code Here

Examples of org.apache.accumulo.core.client.impl.BatchWriterImpl.addMutation()

683
684
685
686
687
688
689
690
691
692
693
      }
      m.putDelete(key.getColumnFamily(), key.getColumnQualifier());
    }

    if (m != null)
      bw.addMutation(m);

    bw.close();
  }

  public static class LogEntry {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.