Interface RecordFilter

    • Method Detail

      • init

        default void init​(Map<String,​String> options)
        Initialiaze the filter.
      • beforeAppend

        default Record beforeAppend​(Record record)
        Called before appending a record to a stream. This hook enables to change the record or to skip it when returning null.
        Parameters:
        record - the record that will be appended to a stream
      • afterAppend

        default void afterAppend​(Record record,
                                 LogOffset offset)
        Called after a record is appended to a stream.
        Parameters:
        record - the written record
        offset - the record's offset
      • afterRead

        default Record afterRead​(Record record,
                                 LogOffset offset)
        Called after reading a record. This hook enables to change the record or to skip it when returning null.
        Parameters:
        record - the record
        offset - the offset of the record