@FrankDocGroup(name="Batch") public interface IResultHandler extends IConfigurable
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
closeBlock(PipeLineSession session,
String streamId,
String blockName,
Map<String,Object> blocks) |
void |
closeDocument(PipeLineSession session,
String streamId) |
void |
closeRecordType(PipeLineSession session,
String streamId) |
String |
finalizeResult(PipeLineSession session,
String streamId,
boolean error)
Called when all records in the original file are handled.
|
void |
handleResult(PipeLineSession session,
String streamId,
String recordKey,
String result)
write a result record.
|
boolean |
hasPrefix() |
boolean |
isBlockByRecordType() |
boolean |
isDefault() |
void |
open() |
void |
openBlock(PipeLineSession session,
String streamId,
String blockName,
Map<String,Object> blocks) |
void |
openDocument(PipeLineSession session,
String streamId)
Called once, before the first record of a stream is presented to handleResult.
|
void |
openRecordType(PipeLineSession session,
String streamId) |
void |
setDefault(boolean isDefault) |
void |
setPipe(AbstractPipe pipe) |
configure
getName, setName
getApplicationContext, getName
getConfigurationClassLoader
void setPipe(AbstractPipe pipe)
void open() throws SenderException
SenderException
void close() throws SenderException
SenderException
void openDocument(PipeLineSession session, String streamId) throws Exception
session
- current PipeLineSessionstreamId
- identification of the original file/stream/messageException
void closeDocument(PipeLineSession session, String streamId)
void handleResult(PipeLineSession session, String streamId, String recordKey, String result) throws Exception
session
- current PipeLineSessionstreamId
- identification of the original file/stream/message containing the untransformed recordsrecordKey
- key of the record (describes the record type)result
- transformed recordException
String finalizeResult(PipeLineSession session, String streamId, boolean error) throws Exception
session
- current PipeLineSessionstreamId
- identification of the original file/stream/message containing the untransformed recordsException
void openRecordType(PipeLineSession session, String streamId) throws Exception
session
- current PipeLineSessionstreamId
- identification of the original file/stream/message containing the untransformed recordsException
void closeRecordType(PipeLineSession session, String streamId) throws Exception
session
- current PipeLineSessionstreamId
- identification of the original file/stream/message containing the untransformed recordsException
void openBlock(PipeLineSession session, String streamId, String blockName, Map<String,Object> blocks) throws Exception
Exception
void closeBlock(PipeLineSession session, String streamId, String blockName, Map<String,Object> blocks) throws Exception
Exception
boolean isDefault()
void setDefault(boolean isDefault)
boolean hasPrefix()
boolean isBlockByRecordType()
newRecordType
to appear in a block.Copyright © 2023 Frank!Framework. All rights reserved.