Interface ChangeStreamRecord

  • All Superinterfaces:
    Serializable
    All Known Implementing Classes:
    ChangeStreamMutation, CloseStream, Heartbeat

    @InternalApi("Intended for use by the BigtableIO in apache/beam only.")
    public interface ChangeStreamRecord
    extends Serializable
    Default representation of a change stream record, which can be a Heartbeat, a CloseStream, or a logical mutation.