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

WriteRowsEventData.getTableId介绍

暂无

代码示例

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

private void processWriteEvent(Event event) {
  WriteRowsEventData data = event.getData();
  Long tableId = data.getTableId();
  List<Serializable[]> list = data.getRows();
  for (Serializable[] row : list) {
    addRow("WRITE", tableId, row);
  }
}

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

long tableNumber = write.getTableId();
BitSet includedColumns = write.getIncludedColumns();
RecordsForTable recordMaker = recordMakers.forTable(tableNumber, includedColumns, super::enqueueRecord);

代码示例来源：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: shyiko/mysql-binlog-connector-java

@Override
public WriteRowsEventData deserialize(ByteArrayInputStream inputStream) throws IOException {
  WriteRowsEventData eventData = new WriteRowsEventData();
  eventData.setTableId(inputStream.readLong(6));
  inputStream.skip(2); // reserved
  if (mayContainExtraInformation) {
    int extraInfoLength = inputStream.readInteger(2);
    inputStream.skip(extraInfoLength - 2);
  }
  int numberOfColumns = inputStream.readPackedInteger();
  eventData.setIncludedColumns(inputStream.readBitSet(numberOfColumns, true));
  eventData.setRows(deserializeRows(eventData.getTableId(), eventData.getIncludedColumns(), inputStream));
  return eventData;
}

代码示例来源：origin: eventuate-local/eventuate-local

private void handleWriteRowsEvent(Event event, Consumer<M> eventConsumer) {
 logger.debug("Got binlog event {}", event);
 offset = ((EventHeaderV4) event.getHeader()).getPosition();
 WriteRowsEventData eventData = event.getData();
 if (tableMapEventByTableId.containsKey(eventData.getTableId())) {
  try {
   eventConsumer.accept(writeRowsEventDataParser.parseEventData(eventData,
       getCurrentBinlogFilename(), offset
       )
   );
  } catch (IOException e) {
   throw new RuntimeException("Event row parsing exception", e);
  }
 }
}

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

WriteRowsEventData d = (WriteRowsEventData) eventData;
if (d.getTableId() == recordTableId) {
  d.getRows().forEach(row -> {
    if (LOGGER.isInfoEnabled()) {

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

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

代码示例来源：origin: networknt/light-eventuate-4j

offset = ((EventHeaderV4) event.getHeader()).getPosition();
WriteRowsEventData eventData = event.getData();
if (tableMapEventByTableId.containsKey(eventData.getTableId())) {
 try {
  eventConsumer.accept(writeRowsEventDataParser.parseEventData(eventData,

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

@Override
public WriteRowsEventData deserialize(ByteArrayInputStream inputStream) throws IOException {
  WriteRowsEventData eventData = new WriteRowsEventData();
  eventData.setTableId(inputStream.readLong(6));
  inputStream.skip(2); // reserved
  if (mayContainExtraInformation) {
    int extraInfoLength = inputStream.readInteger(2);
    inputStream.skip(extraInfoLength - 2);
  }
  int numberOfColumns = inputStream.readPackedInteger();
  eventData.setIncludedColumns(inputStream.readBitSet(numberOfColumns, true));
  eventData.setRows(deserializeRows(eventData.getTableId(), eventData.getIncludedColumns(), inputStream));
  return eventData;
}