Class FlussRowWithOp


  • public class FlussRowWithOp
    extends Object
    A wrapper class that associates an InternalRow with an FlussOperationType for use in Fluss-Flink data processing.

    This class is used to represent a row of data along with its corresponding operation type, such as APPEND, UPSERT, or DELETE, as defined by FlussOperationType.

    See Also:
    InternalRow, FlussOperationType
    • Constructor Detail

      • FlussRowWithOp

        public FlussRowWithOp​(org.apache.fluss.row.InternalRow row,
                              @Nullable
                              FlussOperationType opType)
        Constructs a RowWithOp with the specified internal row and operation type.
        Parameters:
        row - the internal row data (must not be null)
        opType - the operation type (must not be null)
        Throws:
        NullPointerException - if row or opType is null
    • Method Detail

      • getRow

        public org.apache.fluss.row.InternalRow getRow()
        Returns the internal row data.
        Returns:
        the internal row
      • getOperationType

        public FlussOperationType getOperationType()
        Returns the operation type associated with this row.
        Returns:
        the operation type
      • equals

        public boolean equals​(Object o)
        Indicates whether some other object is "equal to" this one. Two RowWithOp objects are considered equal if their internal rows and operation types are equal.
        Overrides:
        equals in class Object
        Parameters:
        o - the reference object with which to compare
        Returns:
        true if this object is the same as the obj argument; false otherwise
      • hashCode

        public int hashCode()
        Returns a hash code value for the object.
        Overrides:
        hashCode in class Object
        Returns:
        a hash code value for this object