List of startUpdate() Examples

Examples of startUpdate()

ch.sahits.game.openpatrician.model.IBalanceSheet.startUpdate()
Start updating the balance sheet with daily updates
ch.sahits.game.openpatrician.model.impl.BalanceSheet.startUpdate()
javax.faces.context.PartialResponseWriter.startUpdate()
org.apache.hadoop.hbase.HTable.startUpdate()
Start an atomic row insertion/update. No changes are committed until the call to commit() returns. A call to abort() will abandon any updates in progress. @param row Name of row to start update against. @return Row lockid.
org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()
Start a batch row insertion/update. No changes are committed until the client commits the batch operation via HClient.batchCommit(). The entire batch update can be abandoned by calling HClient.batchAbort(); Callers to this method are given a handle that corresponds to the row being changed. The handle must be supplied on subsequent put or delete calls. @param row Name of row to start update against. @return Row lockid.
org.openfaces.component.table.impl.TableDataModel.startUpdate()

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()

      // 3. Insert into meta
          
      HRegionInfo info = region.getRegionInfo();
      Text regionName = region.getRegionName();
      BatchUpdate b = new BatchUpdate(rand.nextLong());
      long lockid = b.startUpdate(regionName);
      b.put(lockid, COL_REGIONINFO, Writables.getBytes(info));
      server.batchUpdate(metaRegionName, System.currentTimeMillis(), b);


      // 4. Close the new region to flush it to disk.  Close its log file too.

View Full Code Here

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()

        LOG.debug(split.getRegionName().toString()
            +" no longer has references to " + parent.toString());
      }
      
      BatchUpdate b = new BatchUpdate(rand.nextLong());
      long lockid = b.startUpdate(parent);
      b.delete(lockid, splitColumn);
      srvr.batchUpdate(metaRegionName, System.currentTimeMillis(), b);
        
      return result;
    }

View Full Code Here

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()

      // 3. Insert into meta
          
      HRegionInfo info = region.getRegionInfo();
      Text regionName = region.getRegionName();
      BatchUpdate b = new BatchUpdate(rand.nextLong());
      long lockid = b.startUpdate(regionName);
      b.put(lockid, COL_REGIONINFO, Writables.getBytes(info));
      server.batchUpdate(metaRegionName, b);


      // 4. Close the new region to flush it to disk.  Close its log file too.

View Full Code Here

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()

        LOG.debug(split.getRegionName().toString()
            +" no longer has references to " + parent.toString());
      }
      
      BatchUpdate b = new BatchUpdate(rand.nextLong());
      long lockid = b.startUpdate(parent);
      b.delete(lockid, splitColumn);
      srvr.batchUpdate(metaRegionName, b);
        
      return result;
    }

View Full Code Here

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()

          metaRegionName + " with startcode " +
          Writables.bytesToLong(this.startCode) + " and server "+
          serverAddress.toString());
        try {
          BatchUpdate b = new BatchUpdate(rand.nextLong());
          long lockid = b.startUpdate(regionInfo.getRegionName());
          b.put(lockid, COL_SERVER,
            Writables.stringToBytes(serverAddress.toString()));
          b.put(lockid, COL_STARTCODE, startCode);
          server.batchUpdate(metaRegionName, b);
          if (isMetaTable) {

View Full Code Here

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()

        if (LOG.isDebugEnabled()) {
          LOG.debug("updating columns in row: " + i.getRegionName());
        }


        BatchUpdate b = new BatchUpdate(rand.nextLong());
        lockid = b.startUpdate(i.getRegionName());
        updateRegionInfo(b, i);
        b.delete(lockid, COL_SERVER);
        b.delete(lockid, COL_STARTCODE);
        server.batchUpdate(m.getRegionName(), b);
        if (LOG.isDebugEnabled()) {

View Full Code Here

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()

        if (LOG.isDebugEnabled()) {
          LOG.debug("updating columns in row: " + i.getRegionName());
        }


        BatchUpdate b = new BatchUpdate(rand.nextLong());
        long lockid = b.startUpdate(i.getRegionName());
        updateRegionInfo(lockid, b, i);
        server.batchUpdate(m.getRegionName(), b);
        if (LOG.isDebugEnabled()) {
          LOG.debug("updated columns in row: " + i.getRegionName());
        }

View Full Code Here

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()


    protected void updateRegionInfo(HRegionInterface server, Text regionName,
        HRegionInfo i) throws IOException {


      BatchUpdate b = new BatchUpdate(rand.nextLong());
      long lockid = b.startUpdate(i.getRegionName());
      b.put(lockid, COL_REGIONINFO, Writables.getBytes(i));
      server.batchUpdate(regionName, b);
      if (LOG.isDebugEnabled()) {
        LOG.debug("updated columns in row: " + i.getRegionName());
      }

View Full Code Here

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()

          oldRegion2
      };
      for(int r = 0; r < regionsToDelete.length; r++) {
        long lockid = Math.abs(rand.nextLong());
        BatchUpdate b = new BatchUpdate(lockid);
        lockid = b.startUpdate(regionsToDelete[r]);
        b.delete(lockid, COL_REGIONINFO);
        b.delete(lockid, COL_SERVER);
        b.delete(lockid, COL_STARTCODE);
        b.delete(lockid, COL_SPLITA);
        b.delete(lockid, COL_SPLITB);

View Full Code Here

Examples of org.apache.hadoop.hbase.io.BatchUpdate.startUpdate()

      }
      HRegionInfo newInfo = newRegion.getRegionInfo();
      newInfo.setOffline(true);
      long lockid = Math.abs(rand.nextLong());
      BatchUpdate b = new BatchUpdate(lockid);
      lockid = b.startUpdate(newRegion.getRegionName());
      b.put(lockid, COL_REGIONINFO, Writables.getBytes(newInfo));
      root.batchUpdate(System.currentTimeMillis(), b);
      if(LOG.isDebugEnabled()) {
        LOG.debug("updated columns in row: " + newRegion.getRegionName());
      }

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.