|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface PipelineComponentRuntimeContext
The PipelineComponentRuntimeContext
provides interfaces for
outputting records, logging, and obtaining additional information
about the context in which the associated PipelineComponentRuntime
is running.
Method Summary | |
---|---|
PipelineComponentContext |
getComponentContext()
Returns the PipelineComponentContext. |
ErrorChannel |
getErrorChannel()
Returns an interface for discarding invalid records. |
OutputChannel |
getOutputChannel()
Returns an interface for outputting created or processed records. |
String |
getRecordIdProperty()
Gets the name of the property that is unique per record. |
File |
getStateDir()
Returns the directory that the associated PipelineComponentRuntime
can use to store state. |
boolean |
isStopped()
Returns true if the pipeline should stop processing records because a stop has been requested. |
Method Detail |
---|
OutputChannel getOutputChannel()
OutputChannel
to use for outputting recordsErrorChannel getErrorChannel()
ErrorChannel
to use for discarding recordsFile getStateDir()
PipelineComponentRuntime
can use to store state.
String getRecordIdProperty()
PipelineComponentContext getComponentContext()
boolean isStopped()
PipelineComponentRuntime.stop()
,
PipelineStoppedException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |