@Internal public class StagingSinkJobStatusHook extends Object implements JobStatusHook
StagedTable
on job status changes.Constructor and Description |
---|
StagingSinkJobStatusHook(StagedTable stagedTable) |
Modifier and Type | Method and Description |
---|---|
void |
onCanceled(JobID jobId)
When job get canceled by users.
|
void |
onCreated(JobID jobId)
When Job becomes
JobStatus.CREATED status, it would only be called one time. |
void |
onFailed(JobID jobId,
Throwable throwable)
When job failed finally.
|
void |
onFinished(JobID jobId)
When job finished successfully.
|
public StagingSinkJobStatusHook(StagedTable stagedTable)
public void onCreated(JobID jobId)
JobStatusHook
JobStatus.CREATED
status, it would only be called one time.onCreated
in interface JobStatusHook
public void onFinished(JobID jobId)
JobStatusHook
onFinished
in interface JobStatusHook
public void onFailed(JobID jobId, Throwable throwable)
JobStatusHook
onFailed
in interface JobStatusHook
public void onCanceled(JobID jobId)
JobStatusHook
onCanceled
in interface JobStatusHook
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.