DbSyncer/dbsyncer-parser/src/main/java/org/dbsyncer/parser/model/WriterRequest.java

package org.dbsyncer.parser.model;

import org.dbsyncer.common.event.ChangedEvent;
import org.dbsyncer.common.event.ChangedOffset;
import org.dbsyncer.parser.flush.BufferRequest;

import java.util.Map;

/**
 * @author AE86
 * @version 1.0.0
 * @date 2022/3/27 16:57
 */
public class WriterRequest extends AbstractWriter implements BufferRequest {

    private Map row;

    private ChangedOffset changedOffset;

    public WriterRequest(String tableGroupId, ChangedEvent event) {
        setTableGroupId(tableGroupId);
        setEvent(event.getEvent());
        this.row = event.getChangedRow();
        this.changedOffset = event.getChangedOffset();
    }

    @Override
    public String getMetaId() {
        return changedOffset.getMetaId();
    }
    
    public Map getRow() {
        return row;
    }

    public ChangedOffset getChangedOffset() {
        return changedOffset;
    }
}