org.apache.ignite.internal.management.cdc

Class CdcResendCommand

java.lang.Object

org.apache.ignite.internal.management.cdc.CdcResendCommand

All Implemented Interfaces:

Command<CdcResendCommandArg,Void>, ComputeCommand<CdcResendCommandArg,Void>

public class CdcResendCommand
extends Object
implements ComputeCommand<CdcResendCommandArg,Void>

The command to forcefully resend all cache data to CDC. Iterates over given caches and writes data entries to the WAL to get captured by CDC.

Field Summary

Fields inherited from interface org.apache.ignite.internal.management.api.Command

CMD_NAME_POSTFIX

Constructor Summary

Constructors

Constructor and Description
CdcResendCommand()

Method Summary

Modifier and Type	Method and Description
Class<CdcResendCommandArg>	argClass()
String	description() Command description.
void	printResult(CdcResendCommandArg arg, Void res, Consumer<String> printer) Prints command result to the user.
Class<CdcCacheDataResendTask>	taskClass()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.management.api.ComputeCommand

nodes

Methods inherited from interface org.apache.ignite.internal.management.api.Command

confirmationPrompt, deprecationMessage

Constructor Detail

CdcResendCommand

public CdcResendCommand()

Method Detail

description

public String description()

Command description.

Specified by:

description in interface Command<CdcResendCommandArg,Void>

argClass

public Class<CdcResendCommandArg> argClass()

Specified by:

argClass in interface Command<CdcResendCommandArg,Void>

Returns:

Arguments class.

taskClass

public Class<CdcCacheDataResendTask> taskClass()

Specified by:

taskClass in interface ComputeCommand<CdcResendCommandArg,Void>

Returns:

Task class.

printResult

public void printResult(CdcResendCommandArg arg,
                        Void res,
                        Consumer<String> printer)

Prints command result to the user.

Specified by:

printResult in interface ComputeCommand<CdcResendCommandArg,Void>

Parameters:

arg - Argument.

res - Result.

printer - Implementation specific printer.