Package org.apache.beam.sdk.io.contextualtextio

Class RecordWithMetadata

java.lang.Object
org.apache.beam.sdk.io.contextualtextio.RecordWithMetadata
public class RecordWithMetadata extends Object
Helper Class based on Row, it provides Metadata associated with each Record when reading from file(s) using ContextualTextIO.

Fields:

  • recordValue: The value / contents of the record VALUE
  • resourceId: A resource descriptor representing which resource the record belongs to. See
  • recordNum: The ordinal number of the record in its file. RECORD_NUM RecordWithMetadata.ResourceIdRow for details.
  • rangeOffset: The starting offset of the range (split), which contained the record, when the record was read. RANGE_OFFSET
  • recordNumInOffset: The record number relative to the Range. (line number within the range) RECORD_NUM_IN_OFFSET
  • recordOffset: The offset of a record (the byte at which the record begins) in a file. This information can be useful if you wish to reconstruct the file. RANGE_OFFSET