protected void handleInsert(Event event) throws InterruptedException {
        handleChange(event, "insert", WriteRowsEventData.class, x -> taskContext.getSchema().getTableId(x.getTableId()),
                WriteRowsEventData::getRows,
                (tableId, row) -> eventDispatcher.dispatchDataChangeEvent(tableId,
                        new MySqlChangeRecordEmitter(offsetContext, clock, Operation.CREATE, null, row)));
    }
Generate source records for the supplied event with an {@link WriteRowsEventData}.

@param event the database change data event to be processed; may not be null
@throws InterruptedException if this thread is interrupted while blocking
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java