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

java.lang.Object
- org.apache.flink.cdc.connectors.fluss.source.reader.LeaseContext

All Implemented Interfaces:

Serializable
```
public class LeaseContext
extends Object
implements Serializable
```
Context for a Fluss KV snapshot lease.

See Also:

Serialized Form

Constructor Summary

Constructors
Constructor Description

LeaseContext(String kvSnapshotLeaseId, long kvSnapshotLeaseDurationMs)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`static LeaseContext`	`fromConf(org.apache.flink.configuration.ReadableConfig tableOptions)`
`long`	`getKvSnapshotLeaseDurationMs()`
`String`	`getKvSnapshotLeaseId()`

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

Constructor Detail

LeaseContext

public LeaseContext(String kvSnapshotLeaseId,
                    long kvSnapshotLeaseDurationMs)

Method Detail

fromConf

public static LeaseContext fromConf(org.apache.flink.configuration.ReadableConfig tableOptions)

getKvSnapshotLeaseId
```
public String getKvSnapshotLeaseId()
```

getKvSnapshotLeaseDurationMs

public long getKvSnapshotLeaseDurationMs()