public class SupportedHdfsActiveSyncProvider extends Object implements HdfsActiveSyncProvider
Constructor and Description |
---|
SupportedHdfsActiveSyncProvider(URI uri,
org.apache.hadoop.conf.Configuration conf,
UnderFileSystemConfiguration ufsConf)
Constructor for supported Hdfs Active Sync Provider.
|
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.
|
public SupportedHdfsActiveSyncProvider(URI uri, org.apache.hadoop.conf.Configuration conf, UnderFileSystemConfiguration ufsConf) throws IOException
uri
- the hdfs uriconf
- the hdfs confufsConf
- Alluxio UFS configurationIOException
public boolean startPolling(long txId) throws IOException
HdfsActiveSyncProvider
startPolling
in interface HdfsActiveSyncProvider
txId
- transaction id to start monitoringIOException
public boolean stopPolling()
HdfsActiveSyncProvider
stopPolling
in interface HdfsActiveSyncProvider
public void startSync(AlluxioURI ufsUri)
startSync
in interface HdfsActiveSyncProvider
ufsUri
- the ufs uri to monitor for syncpublic void stopSync(AlluxioURI ufsUri)
stopSync
in interface HdfsActiveSyncProvider
ufsUri
- the ufs uri to stop monitoring for syncpublic void pollEvent(org.apache.hadoop.hdfs.DFSInotifyEventInputStream eventStream)
eventStream
- event streampublic SyncInfo getActivitySyncInfo()
getActivitySyncInfo
in interface HdfsActiveSyncProvider
Copyright © 2023. All Rights Reserved.