org.youngmonkeys.ezyplatform.admin.appender

Class AdminDataAppender<V,D,P>

java.lang.Object

com.tvd12.ezyfox.util.EzyLoggable

org.youngmonkeys.ezyplatform.admin.appender.AdminDataAppender<V,D,P>

Direct Known Subclasses:

AdminAbstractIndexAppender, AdminDataCountAppender, AdminLinkAppender, AdminUserIndexAppender

public abstract class AdminDataAppender<V,D,P>
extends com.tvd12.ezyfox.util.EzyLoggable

Field Summary

Fields

Modifier and Type	Field	Description
protected String	appenderStartedSettingName
protected AtomicReference<P>	lastPageToken
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected String	pageTokenKey
protected AdminSettingService	settingService
protected AtomicBoolean	started

Fields inherited from class com.tvd12.ezyfox.util.EzyLoggable

logger

Constructor Summary

Constructors

Constructor	Description
AdminDataAppender(com.fasterxml.jackson.databind.ObjectMapper objectMapper, AdminSettingService settingService)

Method Summary

Modifier and Type	Method	Description
protected void	addDataRecord(D dataRecord)
protected void	addDataRecords(List<D> dataRecords)
void	append()
protected Stream<D>	dataRecordsToStream(List<D> dataRecords)
protected abstract P	defaultPageToken()
protected boolean	defaultStarted()
protected void	doAppend()
protected abstract P	extractNewLastPageToken(List<V> valueList, P currentLastPageToken)
protected List<V>	filterValueList(List<V> valueList)
protected abstract String	getAppenderNamePrefix()
String	getAppenderStartedSettingName()
String	getName()
int	getPriority()
protected abstract List<V>	getValueList(P pageToken)
boolean	isRunnable()
boolean	isStarted()
protected P	loadLastPageToken()
protected abstract Class<P>	pageTokenType()
void	reload()
protected String	serializePageToken(P pageToken)
void	start()
void	stop()
protected D	toDataRecord(V value)
protected List<D>	toDataRecords(List<V> valueList)
protected Collection<D>	toDataRecords(V value)
String	toString()

Methods inherited from class com.tvd12.ezyfox.util.EzyLoggable

getLogger

Methods inherited from class java.lang.Object

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

Field Detail

started

protected final AtomicBoolean started

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

settingService

protected final AdminSettingService settingService

lastPageToken

protected final AtomicReference<P> lastPageToken

pageTokenKey

protected final String pageTokenKey

appenderStartedSettingName

protected final String appenderStartedSettingName

Constructor Detail

AdminDataAppender

public AdminDataAppender(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                         AdminSettingService settingService)

Method Detail

defaultStarted

protected boolean defaultStarted()

start

public void start()

stop

public void stop()

isStarted

public boolean isStarted()

isRunnable

public boolean isRunnable()

append

public final void append()

doAppend

protected void doAppend()

getValueList

protected abstract List<V> getValueList(P pageToken)

filterValueList

protected List<V> filterValueList(List<V> valueList)

toDataRecord

protected D toDataRecord(V value)

toDataRecords

protected List<D> toDataRecords(List<V> valueList)

toDataRecords

protected Collection<D> toDataRecords(V value)

addDataRecords

protected void addDataRecords(List<D> dataRecords)

dataRecordsToStream

protected Stream<D> dataRecordsToStream(List<D> dataRecords)

addDataRecord

protected void addDataRecord(D dataRecord)

extractNewLastPageToken

protected abstract P extractNewLastPageToken(List<V> valueList,
                                             P currentLastPageToken)

serializePageToken

protected String serializePageToken(P pageToken)

loadLastPageToken

protected P loadLastPageToken()

getAppenderNamePrefix

protected abstract String getAppenderNamePrefix()

defaultPageToken

protected abstract P defaultPageToken()

pageTokenType

protected abstract Class<P> pageTokenType()

reload

public void reload()

getName

public String getName()

getAppenderStartedSettingName

public String getAppenderStartedSettingName()

getPriority

public int getPriority()

toString

public String toString()

Overrides:

toString in class Object