Methods
constructQueryExecutor
constructQueryExecutor( $jobId) : \DruidFamiliar\QueryExecutor\DruidNodeDruidQueryExecutor
constructQueryGenerator
constructQueryGenerator() : \PhpDruidIngest\QueryGenerator\IndexingTaskStatusQueryGenerator
constructQueryParameters
constructQueryParameters() : \PhpDruidIngest\QueryParameters\IndexingTaskStatusQueryParameters
constructQueryResponseHandler
constructQueryResponseHandler() : \PhpDruidIngest\ResponseHandler\IndexingTaskStatusResponseHandler
Wait to retry watching for a pending job.
doWait( $waitDelay)
getDruidIp
getDruidIp() : mixed
getDruidPort
getDruidPort() : mixed
getOutput
getOutput() : \Psr\Log\LoggerInterface
Response
\Psr\Log\LoggerInterface
getProtocol
getProtocol() : string
getWatchAttempts
getWatchAttempts() : integer
handleTaskStatus
handleTaskStatus(\PhpDruidIngest\QueryResponse\IndexingTaskStatusQueryResponse $response) : boolean
Arguments
Response
boolean
Called when a job's status moves to Completed state.
onJobCompleted() : mixed
inherited
Called when a job's status moves to a Failed state.
onJobFailed() : mixed
inherited
Called when a job's status is still in a Running/Pending state after watching period ends.
onJobPending() : mixed
inherited
Reset watch attempts.
resetWatchAttempts()
setDruidIp
setDruidIp(mixed $druidIp)
setDruidPort
setDruidPort(mixed $druidPort)
setOutput
setOutput(\Psr\Log\LoggerInterface $output)
Arguments
$output
\Psr\Log\LoggerInterface
setProtocol
setProtocol(string $protocol)
If a job watching can be cancelled, call this to cancel.
stopWatchingJob() : mixed
inherited
Begin watching given job id.
watchJob(string $jobId) : mixed
inherited
Calls either onJobCompleted or onJobFailed unless stopWatchingJob is called first.
If given job is already completed or failed, the appropriate callback will be called.
Arguments
Response
mixed
Properties
output
output : \Psr\Log\LoggerInterface
Type(s)
\Psr\Log\LoggerInterface
druidPathAction
druidPathAction :
The current number of watch attempts for the currently running job
watchAttempts : integer
Maximum number of times will attempt to check a status before giving up
maximumWatchAttempts : integer
Delay between task status polling checks.
watchAttemptDelay : integer
|
var
|
seconds waited between polling
|
Type(s)
integer
Druid Indexing Task Job Id
watchingJobId : string
inherited