Package org.apache.flink.table.execution

Class StagingSinkJobStatusHook

java.lang.Object

org.apache.flink.table.execution.StagingSinkJobStatusHook

All Implemented Interfaces:

Serializable, JobStatusHook

@Internal
public class StagingSinkJobStatusHook
extends Object
implements JobStatusHook

This hook is used to implement atomic semantics for CTAS(CREATE TABLE AS SELECT) or RTAS([CREATE OR] REPLACE TABLE AS SELECT) statement. It'll call the corresponding interfaces of the inner StagedTable on job status changes.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
StagingSinkJobStatusHook(StagedTable stagedTable)

Method Summary

Modifier and Type	Method	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.

Methods inherited from class java.lang.Object

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

Constructor Detail

StagingSinkJobStatusHook

public StagingSinkJobStatusHook(StagedTable stagedTable)

Method Detail

onCreated

public void onCreated(JobID jobId)

Description copied from interface: JobStatusHook

When Job becomes JobStatus.CREATED status, it would only be called one time.

Specified by:

onCreated in interface JobStatusHook

onFinished

public void onFinished(JobID jobId)

Description copied from interface: JobStatusHook

When job finished successfully.

Specified by:

onFinished in interface JobStatusHook

onFailed

public void onFailed(JobID jobId,
                     Throwable throwable)

Description copied from interface: JobStatusHook

When job failed finally.

Specified by:

onFailed in interface JobStatusHook

onCanceled

public void onCanceled(JobID jobId)

Description copied from interface: JobStatusHook

When job get canceled by users.

Specified by:

onCanceled in interface JobStatusHook