org.apache.beam.sdk.values

Class RowWithGetters

java.lang.Object

org.apache.beam.sdk.values.Row

org.apache.beam.sdk.values.RowWithGetters

All Implemented Interfaces:

java.io.Serializable

@Experimental(value=SCHEMAS)
public class RowWithGetters
extends Row

A Concrete subclass of Row that delegates to a set of provided FieldValueGetters.

This allows us to have Row objects for which the actual storage is in another object. For example, the user's type may be a POJO, in which case the provided getters will simple read the appropriate fields from the POJO.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.values.Row

Row.Builder, Row.Equals, Row.FieldValueBuilder

Method Summary

Modifier and Type	Method and Description
boolean	equals(@Nullable java.lang.Object o)
int	getFieldCount() Return the size of data fields.
java.util.List<FieldValueGetter>	getGetters()
java.lang.Object	getGetterTarget()
<T> T	getValue(int fieldIdx) Get value by field index, ClassCastException is thrown if schema doesn't match.
java.util.List<java.lang.Object>	getValues() Return the list of raw unmodified data values to enable 0-copy code.
int	hashCode()

Methods inherited from class org.apache.beam.sdk.values.Row

fromRow, getArray, getArray, getBaseValue, getBaseValue, getBaseValue, getBaseValue, getBaseValues, getBoolean, getBoolean, getByte, getByte, getBytes, getBytes, getDateTime, getDateTime, getDecimal, getDecimal, getDouble, getDouble, getFloat, getFloat, getInt16, getInt16, getInt32, getInt32, getInt64, getInt64, getIterable, getIterable, getLogicalTypeValue, getLogicalTypeValue, getMap, getMap, getRow, getRow, getSchema, getString, getString, getValue, nullRow, toRow, toString, toString, withSchema

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

getValue

public <T> T getValue(int fieldIdx)

Description copied from class: Row

Get value by field index, ClassCastException is thrown if schema doesn't match.

Specified by:

getValue in class Row

getFieldCount

public int getFieldCount()

Description copied from class: Row

Return the size of data fields.

Specified by:

getFieldCount in class Row

getValues

@Internal
public java.util.List<java.lang.Object> getValues()

Return the list of raw unmodified data values to enable 0-copy code.

Specified by:

getValues in class Row

getGetters

public java.util.List<FieldValueGetter> getGetters()

getGetterTarget

public java.lang.Object getGetterTarget()

equals

public boolean equals(@Nullable java.lang.Object o)

Overrides:

equals in class Row

hashCode

public int hashCode()

Overrides:

hashCode in class Row