Package org.apache.druid.indexing.template

Class BatchIndexingJob

java.lang.Object

org.apache.druid.indexing.template.BatchIndexingJob

public class BatchIndexingJob
extends Object

A batch indexing job that can be launched by the Overlord as a task. A job may contain the ClientTaskQuery itself or an MSQ query that gets converted by the Broker to a ControllerTask and is then submitted to the Overlord.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BatchIndexingJob(ClientTaskQuery task, ClientSqlQuery msqQuery)

Method Summary

Modifier and Type	Method	Description
ClientSqlQuery	getNonNullMsqQuery()
ClientTaskQuery	getNonNullTask()
boolean	isMsq()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

BatchIndexingJob

protected BatchIndexingJob(@Nullable
 ClientTaskQuery task,
 @Nullable
 ClientSqlQuery msqQuery)

Method Details

getNonNullMsqQuery

public ClientSqlQuery getNonNullMsqQuery()

Returns:

MSQ query to be run in this job, if any.

Throws:

NullPointerException - if this not an MSQ job.

getNonNullTask

public ClientTaskQuery getNonNullTask()

Returns:

Task to be run in this job, if any.

Throws:

NullPointerException - if this is an MSQ job.

isMsq

public boolean isMsq()

Returns:

true if this is an MSQ SQL job.

toString

public String toString()

Overrides:

toString in class Object