public abstract class AdminDataPipelineProcessingWorker<I,O,P> extends com.tvd12.ezyfox.util.EzyLoggable implements AdminDataPipelineWorker
| Constructor and Description |
|---|
AdminDataPipelineProcessingWorker() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
addOutputValue(O value) |
protected abstract P |
defaultPageToken() |
protected abstract P |
extractNewLastPageToken(List<I> valueList,
P currentLastPageToken) |
protected List<I> |
filterValueList(List<I> valueList) |
protected abstract List<I> |
getValueList(P pageToken) |
protected abstract String |
getWorkerNamePrefix() |
protected abstract Class<P> |
pageTokenType() |
protected void |
preRun() |
void |
reset() |
void |
run() |
protected abstract Collection<O> |
toOutputValues(I value) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetDisplayNamepublic final void run()
run in interface AdminDataPipelineWorkerpublic void reset()
reset in interface AdminDataPipelineWorkerprotected void preRun()
protected abstract Collection<O> toOutputValues(I value)
protected abstract void addOutputValue(O value)
protected abstract P extractNewLastPageToken(List<I> valueList, P currentLastPageToken)
protected abstract String getWorkerNamePrefix()
protected abstract P defaultPageToken()
Copyright © 2024 Young Monkeys. All rights reserved.