Package org.epics.archiverappliance.etl.common

Class ETLPVLookupItems

java.lang.Object

org.epics.archiverappliance.etl.common.ETLPVLookupItems

public class ETLPVLookupItems
extends Object

A POJO for PV name, ETLSource, and ETLDest items, which can be used as elements in a list (e.g., implementations of the ETLPVLookup interface, such as PBThreeTierETLPVLookup).

Author:

rdh

Constructor Summary

Constructors

Constructor	Description
ETLPVLookupItems(String pvName, ArchDBRTypes dbrType, ETLSource source, ETLDest dest, int lifetimeorder, ETLMetricsForLifetime metricsForLifetime, OutOfSpaceHandling outOfSpaceHandling)

Method Summary

Modifier and Type	Method	Description
void	addETLDurationInMillis(long pvETLStartEpochMilliSeconds, long pvETLEndEpochMilliSeconds)
void	addInfoAboutDetailedTime(long time4getETLStreams, long time4checkSizes, long time4prepareForNewPartition, long time4appendToETLAppendData, long time4commitETLAppendData, long time4markForDeletion, long time4runPostProcessors, long time4executePostETLTasks, long totalSrcBytes)
boolean	equals(Object obj)
ScheduledFuture<?>	getCancellingFuture()
ArchDBRTypes	getDbrType()
ETLDest	getETLDest()
ETLSource	getETLSource()
long	getLastETLCompleteEpochSeconds()
long	getLastETLTimeWeSpentInETLInMilliSeconds()
int	getLifetimeorder()
ETLMetricsForLifetime	getMetricsForLifetime()
int	getNumberofTimesWeETLed()
long	getOutOfSpaceChunksDeleted()
OutOfSpaceHandling	getOutOfSpaceHandling()
String	getPvName()
long	getTime4appendToETLAppendData()
long	getTime4checkSizes()
long	getTime4commitETLAppendData()
long	getTime4executePostETLTasks()
long	getTime4getETLStreams()
long	getTime4markForDeletion()
long	getTime4prepareForNewPartition()
long	getTime4runPostProcessors()
long	getTotalSrcBytes()
long	getTotalTimeWeSpentInETLInMilliSeconds()
int	hashCode()
void	outOfSpaceChunkDeleted()
void	setCancellingFuture(ScheduledFuture<?> cancellingFuture)
void	setETLDest(ETLDest dest)
void	setETLSource(ETLSource source)
void	setPvName(String pvName)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ETLPVLookupItems

public ETLPVLookupItems(String pvName,
 ArchDBRTypes dbrType,
 ETLSource source,
 ETLDest dest,
 int lifetimeorder,
 ETLMetricsForLifetime metricsForLifetime,
 OutOfSpaceHandling outOfSpaceHandling)

Method Details

getLifetimeorder

public int getLifetimeorder()

getPvName

public String getPvName()

setPvName

public void setPvName(String pvName)

getETLSource

public ETLSource getETLSource()

setETLSource

public void setETLSource(ETLSource source)

getETLDest

public ETLDest getETLDest()

setETLDest

public void setETLDest(ETLDest dest)

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getTotalTimeWeSpentInETLInMilliSeconds

public long getTotalTimeWeSpentInETLInMilliSeconds()

getNumberofTimesWeETLed

public int getNumberofTimesWeETLed()

getLastETLCompleteEpochSeconds

public long getLastETLCompleteEpochSeconds()

addETLDurationInMillis

public void addETLDurationInMillis(long pvETLStartEpochMilliSeconds,
 long pvETLEndEpochMilliSeconds)

getDbrType

public ArchDBRTypes getDbrType()

getCancellingFuture

public ScheduledFuture<?> getCancellingFuture()

setCancellingFuture

public void setCancellingFuture(ScheduledFuture<?> cancellingFuture)

toString

public String toString()

Overrides:

toString in class Object

addInfoAboutDetailedTime

public void addInfoAboutDetailedTime(long time4getETLStreams,
 long time4checkSizes,
 long time4prepareForNewPartition,
 long time4appendToETLAppendData,
 long time4commitETLAppendData,
 long time4markForDeletion,
 long time4runPostProcessors,
 long time4executePostETLTasks,
 long totalSrcBytes)

getTime4getETLStreams

public long getTime4getETLStreams()

getTime4prepareForNewPartition

public long getTime4prepareForNewPartition()

getTime4appendToETLAppendData

public long getTime4appendToETLAppendData()

getTime4commitETLAppendData

public long getTime4commitETLAppendData()

getTime4markForDeletion

public long getTime4markForDeletion()

getTime4runPostProcessors

public long getTime4runPostProcessors()

getTime4executePostETLTasks

public long getTime4executePostETLTasks()

getOutOfSpaceHandling

public OutOfSpaceHandling getOutOfSpaceHandling()

getOutOfSpaceChunksDeleted

public long getOutOfSpaceChunksDeleted()

outOfSpaceChunkDeleted

public void outOfSpaceChunkDeleted()

getTotalSrcBytes

public long getTotalSrcBytes()

getLastETLTimeWeSpentInETLInMilliSeconds

public long getLastETLTimeWeSpentInETLInMilliSeconds()

getTime4checkSizes

public long getTime4checkSizes()

getMetricsForLifetime

public ETLMetricsForLifetime getMetricsForLifetime()

Returns:

the metricsForLifetime