Package org.apache.druid.metadata

Class TaskLookup.CompleteTaskLookup

java.lang.Object

org.apache.druid.metadata.TaskLookup.CompleteTaskLookup

All Implemented Interfaces:

TaskLookup

Enclosing interface:

TaskLookup

public static class TaskLookup.CompleteTaskLookup
extends Object
implements TaskLookup

Task lookup for complete tasks. It includes optional filters for task lookups. When the filters are given, the task lookup returns only the tasks that satisfy all filters.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.druid.metadata.TaskLookup

TaskLookup.ActiveTaskLookup, TaskLookup.CompleteTaskLookup, TaskLookup.TaskLookupType

Constructor Summary

Constructors

Constructor	Description
CompleteTaskLookup(Integer maxTaskStatuses, org.joda.time.DateTime tasksCreatedPriorTo)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Integer	getMaxTaskStatuses()
org.joda.time.DateTime	getTasksCreatedPriorTo()
TaskLookup.TaskLookupType	getType()
int	hashCode()
boolean	hasTaskCreatedTimeFilter()
boolean	isNil()	Whether this lookup is guaranteed to not return any tasks.
static TaskLookup.CompleteTaskLookup	of(Integer maxTaskStatuses, org.joda.time.Duration durationBeforeNow)
TaskLookup.CompleteTaskLookup	withMinTimestampIfAbsent(org.joda.time.DateTime minTimestamp)	If hasTaskCreatedTimeFilter(), returns this instance.
static TaskLookup.CompleteTaskLookup	withTasksCreatedPriorTo(Integer maxTaskStatuses, org.joda.time.DateTime tasksCreatedPriorTo)

Methods inherited from class java.lang.Object

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

Constructor Details

CompleteTaskLookup

public CompleteTaskLookup(@Nullable
 Integer maxTaskStatuses,
 @Nullable
 org.joda.time.DateTime tasksCreatedPriorTo)

Method Details

of

public static TaskLookup.CompleteTaskLookup of(@Nullable
 Integer maxTaskStatuses,
 @Nullable
 org.joda.time.Duration durationBeforeNow)

withTasksCreatedPriorTo

public static TaskLookup.CompleteTaskLookup withTasksCreatedPriorTo(@Nullable
 Integer maxTaskStatuses,
 @Nullable
 org.joda.time.DateTime tasksCreatedPriorTo)

hasTaskCreatedTimeFilter

public boolean hasTaskCreatedTimeFilter()

withMinTimestampIfAbsent

public TaskLookup.CompleteTaskLookup withMinTimestampIfAbsent(org.joda.time.DateTime minTimestamp)

If hasTaskCreatedTimeFilter(), returns this instance. Otherwise, returns a copy with getTasksCreatedPriorTo() based on the provided duration (before now).

getTasksCreatedPriorTo

public org.joda.time.DateTime getTasksCreatedPriorTo()

getMaxTaskStatuses

@Nullable
public Integer getMaxTaskStatuses()

getType

public TaskLookup.TaskLookupType getType()

Specified by:

getType in interface TaskLookup

isNil

public boolean isNil()

Description copied from interface: TaskLookup

Whether this lookup is guaranteed to not return any tasks.

Specified by:

isNil in interface TaskLookup

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object