Module datarush.library
Package com.pervasive.datarush.operators.io

Interface DataFormat.DataParser

All Known Implementing Classes:
AbstractRegexLogFormat.RegexParser
Enclosing interface:
DataFormat
public static interface DataFormat.DataParser
A parser for record data in binary or text format. A DataParser bridges the gap between records within and outside of a dataflow graph An implementation represents such a mapping for some concrete external format.
See Also:

  • Method Summary

    Modifier and Type
    Method
    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.

  • Method Details

    • bindOutput

      void bindOutput(RecordSettable target)
      Called to provide the target port onto which parsed records are pushed.

      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.

      Parameters:
      target - the output port which receives parsed records

    • parseSplit

      void parseSplit(SplitParsingContext ctx)
      Called to convert an input split into records.

      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.

      Parameters:
      split -

    • release

      void release()
      Called to signal that parsing is complete.

      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.