Type Members

1.  class BerRecordIterator extends Iterator[InternalRow] with AutoCloseable

   Iterator that reads successive ASN.1 BER/DER records from an InputStream, decoding each one against the provided schema.

   Iterator that reads successive ASN.1 BER/DER records from an InputStream, decoding each one against the provided schema.

   The stream is closed when the iterator is exhausted or when close() is called.

2.  class PerRecordIterator extends Iterator[InternalRow] with AutoCloseable

   Iterator that reads successive PER-encoded records from an InputStream.

   Iterator that reads successive PER-encoded records from an InputStream.

   Three framing strategies (controlled by asn1.per.framing):

   • length-prefixed: 4-byte big-endian length prefix per record
   • fixed-length: every record is exactly recordBytes bytes
   • hex-lines: each non-blank line is a hex-encoded record
3.  class XerRecordIterator extends Iterator[InternalRow] with AutoCloseable

   Splits a stream of concatenated XER records into individual elements and decodes each one.

   Splits a stream of concatenated XER records into individual elements and decodes each one.

   Java's StAX parser treats the input as a single-root XML document and stops after the first root element. To work around this, we wrap the raw stream in a synthetic <_xer_root_>…</_xer_root_> envelope so the parser sees a valid single document, then extract records at depth 2.

   Wrapper detection: if the depth-2 element cannot be decoded as a record (e.g. <Records><id>…</id></Records>), its children are extracted and decoded individually. Wrapper-extracted records beyond the first are buffered in pendingRows.