Examples of toThrift()

Examples of org.apache.accumulo.core.data.Mutation.toThrift()

115
116
117
118
119
120
121
122
123
124
125
    }
    assertTrue(fs.exists(mylog));
    Mutation m = new Mutation(new Text("row1"));
    m.put(new Text("cf"), new Text("cq"), new Value("value".getBytes()));
    try {
      writer.log(null, logFile.id, 1, 0, m.toThrift());
      fail("writing to a log after it has been copied to hdfs should fail");
    } catch (NoSuchLogIDException ex) {
      // ignored
    }
    fs.delete(mylog, true);
View Full Code Here

Examples of org.apache.accumulo.core.data.Mutation.toThrift()

149
150
151
152
153
154
155
156
157
158
159
  @Test
  public void testLog() throws Exception {
    LogFile logFile = writer.create(null, CREDENTIALS, "");
    Mutation m = new Mutation(new Text("somerow"));
    m.put(new Text("cf1"), new Text("cq1"), new Value("value1".getBytes()));
    writer.log(null, logFile.id, 2, 42, m.toThrift());
    writer.close(null, logFile.id);
    SequenceFile.Reader dis = readOpen(logFile);
    LogFileKey key = new LogFileKey();
    LogFileValue value = new LogFileValue();
    assertTrue(dis.next(key, value));
View Full Code Here

Examples of org.apache.accumulo.core.data.Mutation.toThrift()

170
171
172
173
174
175
176
177
178
179
180
    LogFile logFile = writer.create(null, CREDENTIALS, "");
    List<TMutation> all = new ArrayList<TMutation>();
    for (int i = 0; i < 10; i++) {
      Mutation m = new Mutation(new Text("somerow"));
      m.put(new Text("cf" + i), new Text("cq" + i), new Value(("value" + i).getBytes()));
      all.add(m.toThrift());
    }
    List<TabletMutations> updates = new ArrayList<TabletMutations>();
    updates.add(new TabletMutations(13, 3, all));
    writer.logManyTablets(null, logFile.id, updates);
    writer.close(null, logFile.id);
View Full Code Here

Examples of org.apache.accumulo.core.data.Mutation.toThrift()

884
885
886
887
888
889
890
891
892
893
894
              long size = 0;
              Iterator<Mutation> iter = entry.getValue().iterator();
              while (iter.hasNext()) {
                while (size < MUTATION_BATCH_SIZE && iter.hasNext()) {
                  Mutation mutation = iter.next();
                  updates.add(mutation.toThrift());
                  size += mutation.numBytes();
                }
               
                client.applyUpdates(tinfo, usid, entry.getKey().toThrift(), updates);
                updates.clear();
View Full Code Here

Examples of org.apache.accumulo.core.data.Mutation.toThrift()

884
885
886
887
888
889
890
891
892
893
894
              long size = 0;
              Iterator<Mutation> iter = entry.getValue().iterator();
              while (iter.hasNext()) {
                while (size < MUTATION_BATCH_SIZE && iter.hasNext()) {
                  Mutation mutation = iter.next();
                  updates.add(mutation.toThrift());
                  size += mutation.numBytes();
                }
               
                client.applyUpdates(tinfo, usid, entry.getKey().toThrift(), updates);
                updates.clear();
View Full Code Here

Examples of org.apache.accumulo.core.data.Range.toThrift()

179
180
181
182
183
184
185
186
187
188
189
       
        row.getBytes()[row.getLength() - 1] = (byte) (row.getBytes()[row.getLength() - 1] - 1);
      }
     
      Range r = new Range(row, true, row2, false);
      batch.put(keyExtent.toThrift(), Collections.singletonList(r.toThrift()));
    }
    TInfo tinfo = Tracer.traceInfo();
    Map<String,Map<String,String>> emptyMapSMapSS = Collections.emptyMap();
    List<IterInfo> emptyListIterInfo = Collections.emptyList();
    List<TColumn> emptyListColumn = Collections.emptyList();
View Full Code Here

Examples of org.apache.accumulo.core.data.Range.toThrift()

234
235
236
237
238
239
240
241
242
243
244
       
        row.getBytes()[row.getLength() - 1] = (byte) (row.getBytes()[row.getLength() - 1] - 1);
      }
     
      Range r = new Range(row, true, row2, false);
      batch.put(keyExtent.toThrift(), Collections.singletonList(r.toThrift()));
    }
   
    Map<String,Map<String,String>> emptyMapSMapSS = Collections.emptyMap();
    List<IterInfo> emptyListIterInfo = Collections.emptyList();
    List<TColumn> emptyListColumn = Collections.emptyList();
View Full Code Here

Examples of org.apache.accumulo.core.security.Credentials.toThrift()

103
104
105
106
107
108
109
110
111
112
113
    int unassignedTablets = 1;
    for (int i = 0; unassignedTablets > 0 && i < 10; i++) {
      MasterClientService.Iface client = null;
      try {
        client = MasterClient.getConnectionWithRetry(c.getInstance());
        stats = client.getMasterStats(Tracer.traceInfo(), creds.toThrift(c.getInstance()));
      } finally {
        if (client != null)
          MasterClient.close(client);
      }
      unassignedTablets = stats.getUnassignedTablets();
View Full Code Here

Examples of org.apache.accumulo.core.security.Credentials.toThrift()

79
80
81
82
83
84
85
86
87
88
89
    int unassignedTablets = 1;
    for (int i = 0; unassignedTablets > 0 && i < 10; i++) {
      MasterClientService.Iface client = null;
      try {
        client = MasterClient.getConnectionWithRetry(c.getInstance());
        stats = client.getMasterStats(Tracer.traceInfo(), creds.toThrift(c.getInstance()));
      } finally {
        if (client != null)
          MasterClient.close(client);
      }
      unassignedTablets = stats.getUnassignedTablets();
View Full Code Here

Examples of org.apache.cassandra.config.CFMetaData.toThrift()

55
56
57
58
59
60
61
62
63
64
65
        {
            CFMetaData oldCfm = ThriftValidation.validateColumnFamily(keyspace(), columnFamily());
            boolean columnExists = false;
            // mutating oldCfm directly would be bad, but mutating a Thrift copy is fine.  This also
            // sets us up to use validateCfDef to check for index name collisions.
            CfDef cf_def = oldCfm.toThrift();
            for (ColumnDef cd : cf_def.column_metadata)
            {
                if (cd.name.equals(columnName.key))
                {
                    if (cd.index_type != null)
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.