Package org.apache.nifi.processors.standard

Class MonitorActivity.LocalFlowActivityInfo

java.lang.Object

org.apache.nifi.processors.standard.MonitorActivity.LocalFlowActivityInfo

Enclosing class:

MonitorActivity

private class MonitorActivity.LocalFlowActivityInfo
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private long	lastSuccessfulTransfer
private Map<String,String>	lastSuccessfulTransferAttributes
private long	nextSyncMillis
private static final long	NO_VALUE
private final boolean	saveAttributes
private final long	startupTimeMillis
private final long	syncPeriodMillis
private final long	thresholdMillis
private static final int	TIMES_SYNC_WITHIN_THRESHOLD

Constructor Summary

Constructors

Constructor	Description
LocalFlowActivityInfo(long startupTimeMillis, long thresholdMillis, boolean saveAttributes)
LocalFlowActivityInfo(long startupTimeMillis, long thresholdMillis, boolean saveAttributes, long initialLastSuccessfulTransfer)

Method Summary

Modifier and Type	Method	Description
void	forceSync()
long	getLastActivity()
long	getLastSuccessfulTransfer()
Map<String,String>	getLastSuccessfulTransferAttributes()
boolean	hasSuccessfulTransfer()
boolean	isActive()
void	setNextSyncMillis()
boolean	syncNeeded()
void	update(org.apache.nifi.flowfile.FlowFile flowFile)
void	update(MonitorActivity.CommonFlowActivityInfo commonFlowActivityInfo)

Methods inherited from class java.lang.Object

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

Field Details

NO_VALUE

private static final long NO_VALUE

See Also:

• Constant Field Values

TIMES_SYNC_WITHIN_THRESHOLD

private static final int TIMES_SYNC_WITHIN_THRESHOLD

See Also:

• Constant Field Values

startupTimeMillis

private final long startupTimeMillis

thresholdMillis

private final long thresholdMillis

saveAttributes

private final boolean saveAttributes

syncPeriodMillis

private final long syncPeriodMillis

nextSyncMillis

private long nextSyncMillis

lastSuccessfulTransfer

private long lastSuccessfulTransfer

lastSuccessfulTransferAttributes

private Map<String,String> lastSuccessfulTransferAttributes

Constructor Details

LocalFlowActivityInfo

public LocalFlowActivityInfo(long startupTimeMillis,
 long thresholdMillis,
 boolean saveAttributes)

LocalFlowActivityInfo

public LocalFlowActivityInfo(long startupTimeMillis,
 long thresholdMillis,
 boolean saveAttributes,
 long initialLastSuccessfulTransfer)

Method Details

syncNeeded

public boolean syncNeeded()

setNextSyncMillis

public void setNextSyncMillis()

forceSync

public void forceSync()

isActive

public boolean isActive()

hasSuccessfulTransfer

public boolean hasSuccessfulTransfer()

getLastSuccessfulTransfer

public long getLastSuccessfulTransfer()

getLastActivity

public long getLastActivity()

getLastSuccessfulTransferAttributes

public Map<String,String> getLastSuccessfulTransferAttributes()

update

public void update(org.apache.nifi.flowfile.FlowFile flowFile)

update

public void update(MonitorActivity.CommonFlowActivityInfo commonFlowActivityInfo)