IcebergWriterState (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.iceberg.sink.v2.IcebergWriterState

public class IcebergWriterState
extends Object

The state of the IcebergWriter.

Constructor Summary

Constructors
Constructor Description

IcebergWriterState(String jobId, String operatorId)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`boolean`	`equals(Object obj)`
`String`	`getJobId()`
`String`	`getOperatorId()`
`int`	`hashCode()`
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

IcebergWriterState

public IcebergWriterState(String jobId,
                          String operatorId)

Method Detail

getJobId
```
public String getJobId()
```

getOperatorId
```
public String getOperatorId()
```

hashCode
```
public int hashCode()
```
Overrides:

hashCode in class Object

equals
```
public boolean equals(Object obj)
```
Overrides:

equals in class Object

toString
```
public String toString()
```
Overrides:

toString in class Object