alluxio.underfs.hdfs.activesync

Class SupportedHdfsActiveSyncProvider

java.lang.Object

alluxio.underfs.hdfs.activesync.SupportedHdfsActiveSyncProvider

All Implemented Interfaces:

HdfsActiveSyncProvider

public class SupportedHdfsActiveSyncProvider
extends Object
implements HdfsActiveSyncProvider

Supported Hdfs Active Sync Provider.

Constructor Summary

Constructors

Constructor and Description
SupportedHdfsActiveSyncProvider(URI uri, org.apache.hadoop.conf.Configuration conf, UnderFileSystemConfiguration ufsConf) Constructor for supported Hdfs Active Sync Provider.

Method Summary

Modifier and Type	Method and Description
SyncInfo	getActivitySyncInfo() Get the activity sync info.
void	pollEvent(org.apache.hadoop.hdfs.DFSInotifyEventInputStream eventStream) Fetch and process events.
boolean	startPolling(long txId) start polling thread.
void	startSync(AlluxioURI ufsUri) startSync on a ufs uri.
boolean	stopPolling() stop polling thread.
void	stopSync(AlluxioURI ufsUri) stop sync on a ufs uri.

Methods inherited from class java.lang.Object

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

Constructor Detail

SupportedHdfsActiveSyncProvider

public SupportedHdfsActiveSyncProvider(URI uri,
                                       org.apache.hadoop.conf.Configuration conf,
                                       UnderFileSystemConfiguration ufsConf)
                                throws IOException

Constructor for supported Hdfs Active Sync Provider.

Parameters:

uri - the hdfs uri

conf - the hdfs conf

ufsConf - Alluxio UFS configuration

Throws:

IOException

Method Detail

startPolling

public boolean startPolling(long txId)
                     throws IOException

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

Throws:

IOException

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)

startSync on a ufs uri.

Specified by:

startSync in interface HdfsActiveSyncProvider

Parameters:

ufsUri - the ufs uri to monitor for sync

stopSync

public void stopSync(AlluxioURI ufsUri)

stop sync on a ufs uri.

Specified by:

stopSync in interface HdfsActiveSyncProvider

Parameters:

ufsUri - the ufs uri to stop monitoring for sync

pollEvent

public void pollEvent(org.apache.hadoop.hdfs.DFSInotifyEventInputStream eventStream)

Fetch and process events.

Parameters:

eventStream - event stream

getActivitySyncInfo

public SyncInfo getActivitySyncInfo()

Get the activity sync info.

Specified by:

getActivitySyncInfo in interface HdfsActiveSyncProvider

Returns:

SyncInfo object which encapsulates the necessary information about changes