T
- the type of CustomContext
public abstract class AbstractPipelineCustomContext> extends Object implements Pipeline
Constructor and Description |
---|
AbstractPipeline(Pipeline> next) |
Modifier and Type | Method and Description |
---|---|
Pipeline> |
close(WorkerContext context, Tag t, ProcessObject po)
Just calls getNext.
|
Pipeline> |
content(WorkerContext ctx, Tag currentTag, String text, ProcessObject po)
Just calls getNext.
|
String |
getContextKey()
Defaults to the fully qualified class name of the object.
|
T |
getLocalContext(WorkerContext context)
Returns the local context for this class using getContextKey, override this together with getContextKey to change the key usage in case you want to add multiple identical pipelines to the worker.
|
Pipeline> |
getNext()
Returns the next pipeline in line.
|
Pipeline> |
init(WorkerContext context)
The init method allows implementation to initialize the pipeline. e.g.
|
Pipeline> |
open(WorkerContext context, Tag t, ProcessObject po)
Just calls getNext.
|
void |
setNext(Pipeline> next)
setNext method.
|
public AbstractPipeline(Pipeline> next)
next
- the pipeline that's next in the sequence.
public Pipeline> getNext()
Pipeline
getNext
in interface Pipeline<T extends CustomContext>
public Pipeline> open(WorkerContext context, Tag t, ProcessObject po) throws PipelineException
open
in interface Pipeline<T extends CustomContext>
context
- the WorkerContext
t
- the Tag
po
- a processObject to put Writable
s in
PipelineException
- can be thrown to indicate that something went wrong.
public Pipeline> content(WorkerContext ctx, Tag currentTag, String text, ProcessObject po) throws PipelineException
content
in interface Pipeline<T extends CustomContext>
ctx
- the WorkerContext
currentTag
- the Tag
text
- the content
po
- a processObject to put Writable
s in
PipelineException
- can be thrown to indicate that something went wrong.
public Pipeline> close(WorkerContext context, Tag t, ProcessObject po) throws PipelineException
close
in interface Pipeline<T extends CustomContext>
context
- the WorkerContext
t
- the Tag
po
- a processObject to put Writable
s in
PipelineException
- can be thrown to indicate that something went wrong.
public T getLocalContext(WorkerContext context) throws PipelineException
context
- the WorkerContext
getContextKey()
PipelineException
- thrown when there is no CustomContext
or the CustomContext is null.
public void setNext(Pipeline> next)
next
- set the next pipeline
public String getContextKey()
getClass().getName()
as name.
public Pipeline> init(WorkerContext context) throws PipelineException
Pipeline
WorkerContext.put(String, CustomContext)
.
init
in interface Pipeline<T extends CustomContext>
context
- the WorkerContext
PipelineException
- can be thrown to indicate that something went wrong.
Copyright © 2016. All rights reserved.