alluxio.underfs.hdfs

Class NoopHdfsActiveSyncProvider

java.lang.Object

alluxio.underfs.hdfs.NoopHdfsActiveSyncProvider

All Implemented Interfaces:

HdfsActiveSyncProvider

public class NoopHdfsActiveSyncProvider
extends Object
implements HdfsActiveSyncProvider

The noop HDFS Active Sync provider.

Constructor Summary

Constructors

Constructor and Description
NoopHdfsActiveSyncProvider()

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopHdfsActiveSyncProvider

public NoopHdfsActiveSyncProvider()

Method Detail

getActivitySyncInfo

public SyncInfo getActivitySyncInfo()

Description copied from interface: HdfsActiveSyncProvider

Get Active SyncInfo from the sync provider.

Specified by:

getActivitySyncInfo in interface HdfsActiveSyncProvider

Returns:

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

startPolling

public boolean startPolling(long txId)

Description copied from interface: HdfsActiveSyncProvider

start polling thread.

Specified by:

startPolling in interface HdfsActiveSyncProvider

Parameters:

txId - transaction id to start monitoring

Returns:

true if polling thread started successfully

stopPolling

public boolean stopPolling()

Description copied from interface: HdfsActiveSyncProvider

stop polling thread.

Specified by:

stopPolling in interface HdfsActiveSyncProvider

Returns:

true if polling thread stopped successfully

startSync

public void startSync(AlluxioURI ufsUri)

Description copied from interface: HdfsActiveSyncProvider

start syncing on a ufs uri.

Specified by:

startSync in interface HdfsActiveSyncProvider

Parameters:

ufsUri - the ufs uri to monitor

stopSync

public void stopSync(AlluxioURI ufsUri)

Description copied from interface: HdfsActiveSyncProvider

stop syncing on a ufs uri.

Specified by:

stopSync in interface HdfsActiveSyncProvider

Parameters:

ufsUri - the ufs uri to stop monitoring