public static interface DataFormat.DataParser
DataParser
bridges the gap between
records within and outside of a dataflow graph
An implementation represents such a mapping for
some concrete external format.DataFormat.DataFormatter
Modifier and Type | Method and Description |
---|---|
void |
bindOutput(RecordSettable target)
Called to provide the target port onto
which parsed records are pushed.
|
void |
parseSplit(SplitParsingContext ctx)
Called to convert an input split
into records.
|
void |
release()
Called to signal that parsing is
complete.
|
void bindOutput(RecordSettable target)
This method is called once, before any
any calls to parseSplit(SplitParsingContext)
are made. Any one-time
initialization for the parser should
be performed within the implementation
of this method.
target
- the output port which receives
parsed recordsvoid parseSplit(SplitParsingContext ctx)
This method may be called one or
more times, once for each split needing to
be parsed.
The implementation is expected to publish all
records found within the split to the output
passed to bindOutput(RecordSettable)
.
Parsing errors and exceptions should be reported
through the provided context.
split
- void release()
This method is called once,
after the last call to #parseSplit(DataSplit)
.
Any allocated resources which
need to be released should be
handled within the implementation
of this method.
Copyright © 2021 Actian Corporation. All rights reserved.