org.apache.paimon.flink.action

Class ClearConsumerAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.TableActionBase

org.apache.paimon.flink.action.ClearConsumerAction

All Implemented Interfaces:

Action

public class ClearConsumerAction
extends TableActionBase

Clear consumers 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	ClearConsumerAction(String databaseName, String tableName, Map<String,String> catalogConfig)

Method Summary

Modifier and Type	Method and Description
void	run() The execution method of the action.
ClearConsumerAction	withExcludingConsumers(String excludingConsumers)
ClearConsumerAction	withIncludingConsumers(String includingConsumers)

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

ClearConsumerAction

protected ClearConsumerAction(String databaseName,
                              String tableName,
                              Map<String,String> catalogConfig)

Method Detail

withIncludingConsumers

public ClearConsumerAction withIncludingConsumers(@Nullable
                                                  String includingConsumers)

withExcludingConsumers

public ClearConsumerAction withExcludingConsumers(@Nullable
                                                  String excludingConsumers)

run

public void run()
         throws Exception

Description copied from interface: Action

The execution method of the action.

Throws:

Exception