org.apache.beam.sdk.io.contextualtextio

Class RecordWithMetadata

java.lang.Object

org.apache.beam.sdk.io.contextualtextio.RecordWithMetadata

public class RecordWithMetadata
extends java.lang.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 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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	RANGE_OFFSET
static java.lang.String	RECORD_NUM
static java.lang.String	RECORD_NUM_IN_OFFSET
static java.lang.String	RECORD_OFFSET
static java.lang.String	RESOURCE_ID
static java.lang.String	VALUE

Constructor Summary

Constructors

Constructor and Description
RecordWithMetadata()

Method Summary

Modifier and Type	Method and Description
static Schema	getSchema()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

VALUE

public static final java.lang.String VALUE

See Also:

Constant Field Values

RESOURCE_ID

public static final java.lang.String RESOURCE_ID

See Also:

Constant Field Values

RECORD_NUM

public static final java.lang.String RECORD_NUM

See Also:

Constant Field Values

RANGE_OFFSET

public static final java.lang.String RANGE_OFFSET

See Also:

Constant Field Values

RECORD_NUM_IN_OFFSET

public static final java.lang.String RECORD_NUM_IN_OFFSET

See Also:

Constant Field Values

RECORD_OFFSET

public static final java.lang.String RECORD_OFFSET

See Also:

Constant Field Values

Constructor Detail

RecordWithMetadata

public RecordWithMetadata()

Method Detail

getSchema

public static Schema getSchema()