org.apache.beam.sdk.io.hadoop.format

Interface ExternalSynchronization

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

HDFSSynchronization

public interface ExternalSynchronization
extends java.io.Serializable

Provides mechanism for acquiring locks related to the job. Serves as source of unique events among the job.

Method Summary

Modifier and Type	Method and Description
TaskAttemptID	acquireTaskAttemptIdLock(Configuration conf, int taskId) Creates unique TaskAttemptID for given taskId.
TaskID	acquireTaskIdLock(Configuration conf) Creates TaskID with unique id among given job.
void	releaseJobIdLock(Configuration conf) Deletes lock ids bounded with given job if any exists.
boolean	tryAcquireJobLock(Configuration conf) Tries to acquire lock for given job.

Method Detail

tryAcquireJobLock

boolean tryAcquireJobLock(Configuration conf)

Tries to acquire lock for given job.

Parameters:

conf - configuration bounded with given job.

Returns:

true if the lock was acquired, false otherwise.

releaseJobIdLock

void releaseJobIdLock(Configuration conf)

Deletes lock ids bounded with given job if any exists.

Parameters:

conf - hadoop configuration of given job.

acquireTaskIdLock

TaskID acquireTaskIdLock(Configuration conf)

Creates TaskID with unique id among given job.

Parameters:

conf - hadoop configuration of given job.

Returns:

TaskID with unique id among given job.

acquireTaskAttemptIdLock

TaskAttemptID acquireTaskAttemptIdLock(Configuration conf,
                                       int taskId)

Creates unique TaskAttemptID for given taskId.

Parameters:

conf - configuration of given task and job

taskId - id of the task

Returns:

Unique TaskAttemptID for given taskId.