alluxio

Class SyncInfo

java.lang.Object

alluxio.SyncInfo

public class SyncInfo
extends Object

This class is used to represent what the active syncing process should sync.

Field Summary

Fields

Modifier and Type	Field and Description
static long	INVALID_TXID

Constructor Summary

Constructors

Constructor and Description
SyncInfo(Map<AlluxioURI,Set<AlluxioURI>> changedFiles, boolean forceSync, long txId) Constructs a SyncInfo.

Method Summary

Modifier and Type	Method and Description
static SyncInfo	emptyInfo() Returns an empty SyncInfo object.
Set<AlluxioURI>	getChangedFiles(AlluxioURI syncPoint) REturns a set of changed files.
Set<AlluxioURI>	getSyncPoints() Returns a list of sync points.
long	getTxId() returns the transaction id that is synced in this sync period.
boolean	isForceSync() returns true if this sync should happen on the entire directory.

Methods inherited from class java.lang.Object

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

Field Detail

INVALID_TXID

public static final long INVALID_TXID

See Also:

Constant Field Values

Constructor Detail

SyncInfo

public SyncInfo(Map<AlluxioURI,Set<AlluxioURI>> changedFiles,
                boolean forceSync,
                long txId)

Constructs a SyncInfo.

Parameters:

changedFiles - a map mapping syncpoint to changed files

forceSync - force sync the entire directory

txId - the transaction id that is synced in this sync

Method Detail

emptyInfo

public static SyncInfo emptyInfo()

Returns an empty SyncInfo object.

Returns:

emptyInfo object

getSyncPoints

public Set<AlluxioURI> getSyncPoints()

Returns a list of sync points.

Returns:

a list of sync points

getChangedFiles

public Set<AlluxioURI> getChangedFiles(AlluxioURI syncPoint)

REturns a set of changed files.

Parameters:

syncPoint - the syncPoint that we are monitoring

Returns:

a set of sync points

isForceSync

public boolean isForceSync()

returns true if this sync should happen on the entire directory.

Returns:

true if this sync should happen on the entire dir

getTxId

public long getTxId()

returns the transaction id that is synced in this sync period.

Returns:

a transaction id that is synced in this sync period