public static void addWalEventTrackerRows(Queue<WALEventTrackerPayload> walEventPayloads,
    final Connection connection) throws Exception {
    List<Put> puts = new ArrayList<>(walEventPayloads.size());
    for (WALEventTrackerPayload payload : walEventPayloads) {
      final byte[] rowKey = getRowKey(payload);
      final Put put = new Put(rowKey);
      // TODO Do we need to SKIP_WAL ?
      put.setPriority(HConstants.NORMAL_QOS);
      put
        .addColumn(WAL_EVENT_TRACKER_INFO_FAMILY, Bytes.toBytes(RS_COLUMN),
          Bytes.toBytes(payload.getRsName()))
        .addColumn(WAL_EVENT_TRACKER_INFO_FAMILY, Bytes.toBytes(WAL_NAME_COLUMN),
          Bytes.toBytes(payload.getWalName()))
        .addColumn(WAL_EVENT_TRACKER_INFO_FAMILY, Bytes.toBytes(TIMESTAMP_COLUMN),
          Bytes.toBytes(payload.getTimeStamp()))
        .addColumn(WAL_EVENT_TRACKER_INFO_FAMILY, Bytes.toBytes(WAL_STATE_COLUMN),
          Bytes.toBytes(payload.getState()))
        .addColumn(WAL_EVENT_TRACKER_INFO_FAMILY, Bytes.toBytes(WAL_LENGTH_COLUMN),
          Bytes.toBytes(payload.getWalLength()));
      puts.add(put);
    }
    doPut(connection, puts);
  }
Add wal event tracker rows to hbase:waleventtracker table
@param walEventPayloads List of walevents to process
@param connection       Connection to use.
hbase-server/src/main/java/org/apache/hadoop/hbase/namequeues/WALEventTrackerTableAccessor.java