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

WriteRowsEventData.getIncludedColumns介绍

暂无

代码示例

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

public InsertRowsEventInfo(TableInfo tableInfo, Long timestamp, String binlogFilename, Long binlogPosition, WriteRowsEventData data) {
    super(tableInfo, INSERT_EVENT, timestamp, binlogFilename, binlogPosition, data.getIncludedColumns(), data.getRows());
    this.data = data;
  }
}

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

BitSet includedColumns = write.getIncludedColumns();
RecordsForTable recordMaker = recordMakers.forTable(tableNumber, includedColumns, super::enqueueRecord);
if (recordMaker != null) {

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

case EXT_WRITE_ROWS:
  for ( Serializable[] data : writeRowsData().getRows() ) {
    list.add(buildRowMap("insert", position, nextPosition, data, table, writeRowsData().getIncludedColumns(), rowQuery));

代码示例来源：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: org.apache.nifi/nifi-cdc-mysql-processors

public InsertRowsEventInfo(TableInfo tableInfo, Long timestamp, String binlogFilename, Long binlogPosition, WriteRowsEventData data) {
    super(tableInfo, INSERT_EVENT, timestamp, binlogFilename, binlogPosition, data.getIncludedColumns(), data.getRows());
    this.data = data;
  }
}

代码示例来源：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;
}