Class FlussRowWithOp
- java.lang.Object
-
- org.apache.flink.cdc.connectors.fluss.sink.v2.FlussRowWithOp
-
public class FlussRowWithOp extends Object
A wrapper class that associates anInternalRowwith anFlussOperationTypefor 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 Summary
Constructors Constructor Description FlussRowWithOp(org.apache.fluss.row.InternalRow row, FlussOperationType opType)Constructs aRowWithOpwith the specified internal row and operation type.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)Indicates whether some other object is "equal to" this one.FlussOperationTypegetOperationType()Returns the operation type associated with this row.org.apache.fluss.row.InternalRowgetRow()Returns the internal row data.inthashCode()Returns a hash code value for the object.
-
-
-
Constructor Detail
-
FlussRowWithOp
public FlussRowWithOp(org.apache.fluss.row.InternalRow row, @Nullable FlussOperationType opType)Constructs aRowWithOpwith 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- ifroworopTypeis 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. TwoRowWithOpobjects are considered equal if their internal rows and operation types are equal.
-
-