io.druid.indexing.common.actions

Class CheckPointDataSourceMetadataAction

java.lang.Object

io.druid.indexing.common.actions.CheckPointDataSourceMetadataAction

All Implemented Interfaces:

TaskAction<Boolean>

public class CheckPointDataSourceMetadataAction
extends Object
implements TaskAction<Boolean>

Constructor Summary

Constructors

Constructor and Description
CheckPointDataSourceMetadataAction(String supervisorId, String sequenceName, DataSourceMetadata previousCheckPoint, DataSourceMetadata currentCheckPoint)

Method Summary

Modifier and Type	Method and Description
DataSourceMetadata	getCurrentCheckPoint()
DataSourceMetadata	getPreviousCheckPoint()
com.fasterxml.jackson.core.type.TypeReference<Boolean>	getReturnTypeReference()
String	getSequenceName()
String	getSupervisorId()
boolean	isAudited()
Boolean	perform(Task task, TaskActionToolbox toolbox)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

CheckPointDataSourceMetadataAction

public CheckPointDataSourceMetadataAction(String supervisorId,
                                          String sequenceName,
                                          DataSourceMetadata previousCheckPoint,
                                          DataSourceMetadata currentCheckPoint)

Method Detail

getSupervisorId

public String getSupervisorId()

getSequenceName

public String getSequenceName()

getPreviousCheckPoint

public DataSourceMetadata getPreviousCheckPoint()

getCurrentCheckPoint

public DataSourceMetadata getCurrentCheckPoint()

getReturnTypeReference

public com.fasterxml.jackson.core.type.TypeReference<Boolean> getReturnTypeReference()

Specified by:

getReturnTypeReference in interface TaskAction<Boolean>

perform

public Boolean perform(Task task,
                       TaskActionToolbox toolbox)
                throws IOException

Specified by:

perform in interface TaskAction<Boolean>

Throws:

IOException

isAudited

public boolean isAudited()

Specified by:

isAudited in interface TaskAction<Boolean>

toString

public String toString()

Overrides:

toString in class Object