alluxio.underfs.hdfs

Interface HdfsActiveSyncProvider

All Known Implementing Classes:

NoopHdfsActiveSyncProvider, SupportedHdfsActiveSyncProvider

public interface HdfsActiveSyncProvider

Interface for providing HDFS ActiveSync.

Method Summary

Modifier and Type	Method and Description
SyncInfo	getActivitySyncInfo() Get Active SyncInfo from the sync provider.
boolean	startPolling(long txId) start polling thread.
void	startSync(AlluxioURI ufsUri) start syncing on a ufs uri.
boolean	stopPolling() stop polling thread.
void	stopSync(AlluxioURI ufsUri) stop syncing on a ufs uri.

Method Detail

getActivitySyncInfo

SyncInfo getActivitySyncInfo()

Get Active SyncInfo from the sync provider.

Returns:

SyncInfo a syncInfo containing information about what to sync and how to sync

startPolling

boolean startPolling(long txId)
              throws IOException

start polling thread.

Parameters:

txId - transaction id to start monitoring

Returns:

true if polling thread started successfully

Throws:

IOException

stopPolling

boolean stopPolling()

stop polling thread.

Returns:

true if polling thread stopped successfully

startSync

void startSync(AlluxioURI ufsUri)

start syncing on a ufs uri.

Parameters:

ufsUri - the ufs uri to monitor

stopSync

void stopSync(AlluxioURI ufsUri)

stop syncing on a ufs uri.

Parameters:

ufsUri - the ufs uri to stop monitoring