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

UpdateRowsEventData.getTableId介绍

暂无

代码示例

代码示例来源：origin: apache/rocketmq-externals

private void processUpdateEvent(Event event) {
  UpdateRowsEventData data = event.getData();
  Long tableId = data.getTableId();
  List<Map.Entry<Serializable[], Serializable[]>> list = data.getRows();
  for (Map.Entry<Serializable[], Serializable[]> entry : list) {
    addRow("UPDATE", tableId, entry.getValue());
  }
}

代码示例来源：origin: shyiko/mysql-binlog-connector-java

private List<Map.Entry<Serializable[], Serializable[]>> deserializeRows(UpdateRowsEventData eventData,
    ByteArrayInputStream inputStream) throws IOException {
  long tableId = eventData.getTableId();
  BitSet includedColumnsBeforeUpdate = eventData.getIncludedColumnsBeforeUpdate(),
      includedColumns = eventData.getIncludedColumns();
  List<Map.Entry<Serializable[], Serializable[]>> rows =
      new ArrayList<Map.Entry<Serializable[], Serializable[]>>();
  while (inputStream.available() > 0) {
    rows.add(new AbstractMap.SimpleEntry<Serializable[], Serializable[]>(
        deserializeRow(tableId, includedColumnsBeforeUpdate, inputStream),
        deserializeRow(tableId, includedColumns, inputStream)
    ));
  }
  return rows;
}

代码示例来源：origin: debezium/debezium

long tableNumber = update.getTableId();
BitSet includedColumns = update.getIncludedColumns();

代码示例来源：origin: zendesk/maxwell

public Long getTableID() {
  EventData data = event.getData();
  switch ( event.getHeader().getEventType() ) {
    case EXT_WRITE_ROWS:
    case WRITE_ROWS:
      return ((WriteRowsEventData) data).getTableId();
    case EXT_UPDATE_ROWS:
    case UPDATE_ROWS:
      return ((UpdateRowsEventData) data).getTableId();
    case EXT_DELETE_ROWS:
    case DELETE_ROWS:
      return ((DeleteRowsEventData) data).getTableId();
    case TABLE_MAP:
      return ((TableMapEventData) data).getTableId();
  }
  return null;
}

代码示例来源：origin: perfectsense/dari

private List<Map.Entry<Serializable[], Serializable[]>> deserializeRows(UpdateRowsEventData eventData,
    ByteArrayInputStream inputStream) throws IOException {
  long tableId = eventData.getTableId();
  BitSet includedColumnsBeforeUpdate = eventData.getIncludedColumnsBeforeUpdate(),
      includedColumns = eventData.getIncludedColumns();
  List<Map.Entry<Serializable[], Serializable[]>> rows =
      new ArrayList<Map.Entry<Serializable[], Serializable[]>>();
  while (inputStream.available() > 0) {
    rows.add(new AbstractMap.SimpleEntry<Serializable[], Serializable[]>(
        deserializeRow(tableId, includedColumnsBeforeUpdate, inputStream),
        deserializeRow(tableId, includedColumns, inputStream)
    ));
  }
  return rows;
}

代码示例来源：origin: perfectsense/dari

UpdateRowsEventData d = (UpdateRowsEventData) eventData;
if (d.getTableId() == recordTableId) {
  d.getRows().stream().map(Map.Entry::getValue).forEach(row -> {
    if (LOGGER.isInfoEnabled()) {

代码示例来源：origin: perfectsense/dari

tableId = ((WriteRowsEventData) eventData).getTableId();
} else if (EventType.isUpdate(eventType)) {
  tableId = ((UpdateRowsEventData) eventData).getTableId();
} else if (EventType.isDelete(eventType)) {
  tableId = ((DeleteRowsEventData) eventData).getTableId();