org.apache.paimon.flink.action

Class ResetConsumerAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.TableActionBase

org.apache.paimon.flink.action.ResetConsumerAction

All Implemented Interfaces:

Action

public class ResetConsumerAction
extends TableActionBase

Reset consumer action for Flink.

Field Summary

Fields inherited from class org.apache.paimon.flink.action.TableActionBase

identifier, table

Fields inherited from class org.apache.paimon.flink.action.ActionBase

batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ResetConsumerAction(String warehouse, String databaseName, String tableName, Map<String,String> catalogConfig, String consumerId)

Method Summary

Modifier and Type	Method and Description
void	run() The execution method of the action.
ResetConsumerAction	withNextSnapshotIds(Long nextSnapshotId)

Methods inherited from class org.apache.paimon.flink.action.TableActionBase

batchSink

Methods inherited from class org.apache.paimon.flink.action.ActionBase

catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.flink.action.Action

build

Constructor Detail

ResetConsumerAction

protected ResetConsumerAction(String warehouse,
                              String databaseName,
                              String tableName,
                              Map<String,String> catalogConfig,
                              String consumerId)

Method Detail

withNextSnapshotIds

public ResetConsumerAction withNextSnapshotIds(Long nextSnapshotId)

run

public void run()
         throws Exception

Description copied from interface: Action

The execution method of the action.

Throws:

Exception