本文整理了Java中org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore.pushData()方法的一些代码示例，展示了WALProcedureStore.pushData()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WALProcedureStore.pushData()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore
类名称：WALProcedureStore
方法名：pushData

WALProcedureStore.pushData介绍

暂无

代码示例

代码示例来源：origin: apache/hbase

private void delete(long[] procIds) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Delete " + Arrays.toString(procIds));
 }
 final ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  for (int i = 0; i < procIds.length; ++i) {
   ProcedureWALFormat.writeDelete(slot, procIds[i]);
  }
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, Procedure.NO_PROC_ID, procIds);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error("Unable to serialize the procedures: " + Arrays.toString(procIds), e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: apache/hbase

@Override
public void delete(long procId) {
 LOG.trace("Delete {}", procId);
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  ProcedureWALFormat.writeDelete(slot, procId);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, procId, null);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize the procedure: " + procId, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: apache/hbase

@Override
public void update(Procedure<?> proc) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Update " + proc);
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the update
  ProcedureWALFormat.writeUpdate(slot, proc);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.UPDATE, slot, proc.getProcId(), null);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize the procedure: " + proc, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: apache/hbase

@Override
public void delete(Procedure<?> proc, long[] subProcIds) {
 assert proc != null : "expected a non-null procedure";
 assert subProcIds != null && subProcIds.length > 0 : "expected subProcIds";
 if (LOG.isTraceEnabled()) {
  LOG.trace("Update " + proc + " and Delete " + Arrays.toString(subProcIds));
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  ProcedureWALFormat.writeDelete(slot, proc, subProcIds);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, proc.getProcId(), subProcIds);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize the procedure: " + proc, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: apache/hbase

@Override
public void insert(Procedure<?>[] procs) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Insert " + Arrays.toString(procs));
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the insert
  long[] procIds = new long[procs.length];
  for (int i = 0; i < procs.length; ++i) {
   assert !procs[i].hasParent();
   procIds[i] = procs[i].getProcId();
   ProcedureWALFormat.writeInsert(slot, procs[i]);
  }
  // Push the transaction data and wait until it is persisted
  pushData(PushType.INSERT, slot, Procedure.NO_PROC_ID, procIds);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize one of the procedure: " +
    Arrays.toString(procs), e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: apache/hbase

pushData(PushType.INSERT, slot, proc.getProcId(), subProcIds);
} catch (IOException e) {

代码示例来源：origin: com.aliyun.hbase/alihbase-procedure

private void delete(final long[] procIds) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Delete " + Arrays.toString(procIds));
 }
 final ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  for (int i = 0; i < procIds.length; ++i) {
   ProcedureWALFormat.writeDelete(slot, procIds[i]);
  }
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, Procedure.NO_PROC_ID, procIds);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error("Unable to serialize the procedures: " + Arrays.toString(procIds), e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: org.apache.hbase/hbase-procedure

private void delete(long[] procIds) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Delete " + Arrays.toString(procIds));
 }
 final ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  for (int i = 0; i < procIds.length; ++i) {
   ProcedureWALFormat.writeDelete(slot, procIds[i]);
  }
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, Procedure.NO_PROC_ID, procIds);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error("Unable to serialize the procedures: " + Arrays.toString(procIds), e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: com.aliyun.hbase/alihbase-procedure

@Override
public void delete(final long procId) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Delete " + procId);
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  ProcedureWALFormat.writeDelete(slot, procId);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, procId, null);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize the procedure: " + procId, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: org.apache.hbase/hbase-procedure

@Override
public void delete(long procId) {
 LOG.trace("Delete {}", procId);
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  ProcedureWALFormat.writeDelete(slot, procId);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, procId, null);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize the procedure: " + procId, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: com.aliyun.hbase/alihbase-procedure

@Override
public void delete(final Procedure proc, final long[] subProcIds) {
 assert proc != null : "expected a non-null procedure";
 assert subProcIds != null && subProcIds.length > 0 : "expected subProcIds";
 if (LOG.isTraceEnabled()) {
  LOG.trace("Update " + proc + " and Delete " + Arrays.toString(subProcIds));
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  ProcedureWALFormat.writeDelete(slot, proc, subProcIds);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, proc.getProcId(), subProcIds);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize the procedure: " + proc, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: com.aliyun.hbase/alihbase-procedure

@Override
public void update(final Procedure proc) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Update " + proc);
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the update
  ProcedureWALFormat.writeUpdate(slot, proc);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.UPDATE, slot, proc.getProcId(), null);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize the procedure: " + proc, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: org.apache.hbase/hbase-procedure

@Override
public void delete(Procedure<?> proc, long[] subProcIds) {
 assert proc != null : "expected a non-null procedure";
 assert subProcIds != null && subProcIds.length > 0 : "expected subProcIds";
 if (LOG.isTraceEnabled()) {
  LOG.trace("Update " + proc + " and Delete " + Arrays.toString(subProcIds));
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  ProcedureWALFormat.writeDelete(slot, proc, subProcIds);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, proc.getProcId(), subProcIds);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize the procedure: " + proc, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: org.apache.hbase/hbase-procedure

@Override
public void update(Procedure<?> proc) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Update " + proc);
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the update
  ProcedureWALFormat.writeUpdate(slot, proc);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.UPDATE, slot, proc.getProcId(), null);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize the procedure: " + proc, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: org.apache.hbase/hbase-procedure

@Override
public void insert(Procedure<?>[] procs) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Insert " + Arrays.toString(procs));
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the insert
  long[] procIds = new long[procs.length];
  for (int i = 0; i < procs.length; ++i) {
   assert !procs[i].hasParent();
   procIds[i] = procs[i].getProcId();
   ProcedureWALFormat.writeInsert(slot, procs[i]);
  }
  // Push the transaction data and wait until it is persisted
  pushData(PushType.INSERT, slot, Procedure.NO_PROC_ID, procIds);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize one of the procedure: " +
    Arrays.toString(procs), e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: com.aliyun.hbase/alihbase-procedure

@Override
public void insert(final Procedure[] procs) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Insert " + Arrays.toString(procs));
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the insert
  long[] procIds = new long[procs.length];
  for (int i = 0; i < procs.length; ++i) {
   assert !procs[i].hasParent();
   procIds[i] = procs[i].getProcId();
   ProcedureWALFormat.writeInsert(slot, procs[i]);
  }
  // Push the transaction data and wait until it is persisted
  pushData(PushType.INSERT, slot, Procedure.NO_PROC_ID, procIds);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.error(HBaseMarkers.FATAL, "Unable to serialize one of the procedure: " +
    Arrays.toString(procs), e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: com.aliyun.hbase/alihbase-procedure

pushData(PushType.INSERT, slot, proc.getProcId(), subProcIds);
} catch (IOException e) {

代码示例来源：origin: harbby/presto-connectors

@Override
public void delete(final long procId) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Delete " + procId);
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the delete
  ProcedureWALFormat.writeDelete(slot, procId);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.DELETE, slot, procId, null);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.fatal("Unable to serialize the procedure: " + procId, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: harbby/presto-connectors

@Override
public void update(final Procedure proc) {
 if (LOG.isTraceEnabled()) {
  LOG.trace("Update " + proc);
 }
 ByteSlot slot = acquireSlot();
 try {
  // Serialize the update
  ProcedureWALFormat.writeUpdate(slot, proc);
  // Push the transaction data and wait until it is persisted
  pushData(PushType.UPDATE, slot, proc.getProcId(), null);
 } catch (IOException e) {
  // We are not able to serialize the procedure.
  // this is a code error, and we are not able to go on.
  LOG.fatal("Unable to serialize the procedure: " + proc, e);
  throw new RuntimeException(e);
 } finally {
  releaseSlot(slot);
 }
}

代码示例来源：origin: harbby/presto-connectors

pushData(PushType.INSERT, slot, proc.getProcId(), subProcIds);
} catch (IOException e) {