Package org.apache.beam.sdk.values

Class RowWithGetters<T extends @NonNull Object>

java.lang.Object

org.apache.beam.sdk.values.Row

org.apache.beam.sdk.values.RowWithGetters<T>

All Implemented Interfaces:

Serializable

public class RowWithGetters<T extends @NonNull Object>
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	Description
boolean	equals(@Nullable Object o)
int	getFieldCount()	Return the size of data fields.
List<FieldValueGetter<T,Object>>	getGetters()
Object	getGetterTarget()
<W> W	getValue(int fieldIdx)	Get value by field index, ClassCastException is thrown if schema doesn't match.
List<@Nullable 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, sorted, toCamelCase, toRow, toSnakeCase, toString, toString, withSchema

Methods inherited from class java.lang.Object

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

Method Details

getValue

public <W> W 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 List<@Nullable Object> getValues()

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

Specified by:

getValues in class Row

getGetters

public List<FieldValueGetter<T,Object>> getGetters()

getGetterTarget

public Object getGetterTarget()

equals

public boolean equals(@Nullable Object o)

Overrides:

equals in class Row

hashCode

public int hashCode()

Overrides:

hashCode in class Row