Row (Apache Beam 2.20.0)

java.lang.Object
- org.apache.beam.sdk.values.Row

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

RowWithGetters, RowWithStorage
```
@Experimental(value=SCHEMAS)
public abstract class Row
extends java.lang.Object
implements java.io.Serializable
```
Row is an immutable tuple-like schema to represent one element in a PCollection. The fields are described with a Schema.
Schema contains the names for each field and the coder for the whole record, {see @link Schema#getRowCoder()}.

See Also:

Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class Row.Builder
Builder for Row.

static class Row.Equals

Nested Classes
Modifier and Type	Class and Description
`static class`	`Row.Builder` Builder for `Row`.
`static class`	`Row.Equals`

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`equals(java.lang.Object o)`
`<T> java.util.Collection<T>`	`getArray(int idx)` Get an array value by field index, `IllegalStateException` is thrown if schema doesn't match.
`<T> java.util.Collection<T>`	`getArray(java.lang.String fieldName)` Get an array value by field name, `IllegalStateException` is thrown if schema doesn't match.
`java.lang.Boolean`	`getBoolean(int idx)` Get a `Boolean` value by field index, `ClassCastException` is thrown if schema doesn't match.
`java.lang.Boolean`	`getBoolean(java.lang.String fieldName)` Get a `Schema.TypeName.BOOLEAN` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`java.lang.Byte`	`getByte(int idx)` Get a `Schema.TypeName.BYTE` value by field index, `ClassCastException` is thrown if schema doesn't match.
`java.lang.Byte`	`getByte(java.lang.String fieldName)` Get a `Schema.TypeName.BYTE` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`byte[]`	`getBytes(int idx)` Get a `Schema.TypeName.BYTES` value by field index, `ClassCastException` is thrown if schema doesn't match.
`byte[]`	`getBytes(java.lang.String fieldName)` Get a `Schema.TypeName.BYTES` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`ReadableDateTime`	`getDateTime(int idx)` Get a `Schema.TypeName.DATETIME` value by field index, `IllegalStateException` is thrown if schema doesn't match.
`ReadableDateTime`	`getDateTime(java.lang.String fieldName)` Get a `Schema.TypeName.DATETIME` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`java.math.BigDecimal`	`getDecimal(int idx)` Get a `BigDecimal` value by field index, `ClassCastException` is thrown if schema doesn't match.
`java.math.BigDecimal`	`getDecimal(java.lang.String fieldName)` Get a `Schema.TypeName.DECIMAL` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`java.lang.Double`	`getDouble(int idx)` Get a `Schema.TypeName.DOUBLE` value by field index, `ClassCastException` is thrown if schema doesn't match.
`java.lang.Double`	`getDouble(java.lang.String fieldName)` Get a `Schema.TypeName.DOUBLE` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`abstract int`	`getFieldCount()` Return the size of data fields.
`java.lang.Float`	`getFloat(int idx)` Get a `Schema.TypeName.FLOAT` value by field index, `ClassCastException` is thrown if schema doesn't match.
`java.lang.Float`	`getFloat(java.lang.String fieldName)` Get a `Schema.TypeName.FLOAT` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`java.lang.Short`	`getInt16(int idx)` Get a `Schema.TypeName.INT16` value by field index, `ClassCastException` is thrown if schema doesn't match.
`java.lang.Short`	`getInt16(java.lang.String fieldName)` Get a `Schema.TypeName.INT16` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`java.lang.Integer`	`getInt32(int idx)` Get a `Schema.TypeName.INT32` value by field index, `ClassCastException` is thrown if schema doesn't match.
`java.lang.Integer`	`getInt32(java.lang.String fieldName)` Get a `Schema.TypeName.INT32` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`java.lang.Long`	`getInt64(int idx)` Get a `Schema.TypeName.INT64` value by field index, `ClassCastException` is thrown if schema doesn't match.
`java.lang.Long`	`getInt64(java.lang.String fieldName)` Get a `Schema.TypeName.INT64` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`<T> java.lang.Iterable<T>`	`getIterable(int idx)` Get an iterable value by field index, `IllegalStateException` is thrown if schema doesn't match.
`<T> java.lang.Iterable<T>`	`getIterable(java.lang.String fieldName)` Get an iterable value by field name, `IllegalStateException` is thrown if schema doesn't match.
`<T> T`	`getLogicalTypeValue(int idx, java.lang.Class<T> clazz)` Returns the Logical Type input type for this field.
`<T> T`	`getLogicalTypeValue(java.lang.String fieldName, java.lang.Class<T> clazz)` Returns the Logical Type input type for this field.
`<T1,T2> java.util.Map<T1,T2>`	`getMap(int idx)` Get a MAP value by field index, `IllegalStateException` is thrown if schema doesn't match.
`<T1,T2> java.util.Map<T1,T2>`	`getMap(java.lang.String fieldName)` Get a MAP value by field name, `IllegalStateException` is thrown if schema doesn't match.
`Row`	`getRow(int idx)` Get a `Row` value by field index, `IllegalStateException` is thrown if schema doesn't match.
`Row`	`getRow(java.lang.String fieldName)` Get a `Schema.TypeName.ROW` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`Schema`	`getSchema()` Return `Schema` which describes the fields.
`java.lang.String`	`getString(int idx)` Get a `String` value by field index, `ClassCastException` is thrown if schema doesn't match.
`java.lang.String`	`getString(java.lang.String fieldName)` Get a `Schema.TypeName.STRING` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`abstract <T> T`	`getValue(int fieldIdx)` Get value by field index, `ClassCastException` is thrown if schema doesn't match.
`<T> T`	`getValue(java.lang.String fieldName)` Get value by field name, `ClassCastException` is thrown if type doesn't match.
`abstract java.util.List<java.lang.Object>`	`getValues()` Return the list of data values.
`int`	`hashCode()`
`static Row`	`nullRow(Schema schema)` Creates a new record filled with nulls.
`static <T> java.util.stream.Collector<T,java.util.List<java.lang.Object>,Row>`	`toRow(Schema schema)` Creates a `Row` from the list of values and `getSchema()`.
`java.lang.String`	`toString()`
`static Row.Builder`	`withSchema(Schema schema)` Creates a record builder with specified `getSchema()`.

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Method Detail
  - getValue
```
@Nullable
public abstract <T> T getValue(int fieldIdx)
```
    Get value by field index, ClassCastException is thrown if schema doesn't match.
  - getFieldCount
```
public abstract int getFieldCount()
```
    Return the size of data fields.
  - getValues
```
public abstract java.util.List<java.lang.Object> getValues()
```
    Return the list of data values.
  - getValue
```
@Nullable
public <T> T getValue(java.lang.String fieldName)
```
    Get value by field name, ClassCastException is thrown if type doesn't match.
  - getByte
```
@Nullable
public java.lang.Byte getByte(java.lang.String fieldName)
```
    Get a Schema.TypeName.BYTE value by field name, IllegalStateException is thrown if schema doesn't match.
  - getBytes
```
@Nullable
public byte[] getBytes(java.lang.String fieldName)
```
    Get a Schema.TypeName.BYTES value by field name, IllegalStateException is thrown if schema doesn't match.
  - getInt16
```
@Nullable
public java.lang.Short getInt16(java.lang.String fieldName)
```
    Get a Schema.TypeName.INT16 value by field name, IllegalStateException is thrown if schema doesn't match.
  - getInt32
```
@Nullable
public java.lang.Integer getInt32(java.lang.String fieldName)
```
    Get a Schema.TypeName.INT32 value by field name, IllegalStateException is thrown if schema doesn't match.
  - getInt64
```
@Nullable
public java.lang.Long getInt64(java.lang.String fieldName)
```
    Get a Schema.TypeName.INT64 value by field name, IllegalStateException is thrown if schema doesn't match.
  - getDecimal
```
@Nullable
public java.math.BigDecimal getDecimal(java.lang.String fieldName)
```
    Get a Schema.TypeName.DECIMAL value by field name, IllegalStateException is thrown if schema doesn't match.
  - getFloat
```
@Nullable
public java.lang.Float getFloat(java.lang.String fieldName)
```
    Get a Schema.TypeName.FLOAT value by field name, IllegalStateException is thrown if schema doesn't match.
  - getDouble
```
@Nullable
public java.lang.Double getDouble(java.lang.String fieldName)
```
    Get a Schema.TypeName.DOUBLE value by field name, IllegalStateException is thrown if schema doesn't match.
  - getString
```
@Nullable
public java.lang.String getString(java.lang.String fieldName)
```
    Get a Schema.TypeName.STRING value by field name, IllegalStateException is thrown if schema doesn't match.
  - getDateTime
```
@Nullable
public ReadableDateTime getDateTime(java.lang.String fieldName)
```
    Get a Schema.TypeName.DATETIME value by field name, IllegalStateException is thrown if schema doesn't match.
  - getBoolean
```
@Nullable
public java.lang.Boolean getBoolean(java.lang.String fieldName)
```
    Get a Schema.TypeName.BOOLEAN value by field name, IllegalStateException is thrown if schema doesn't match.
  - getArray
```
@Nullable
public <T> java.util.Collection<T> getArray(java.lang.String fieldName)
```
    Get an array value by field name, IllegalStateException is thrown if schema doesn't match.
  - getIterable
```
@Nullable
public <T> java.lang.Iterable<T> getIterable(java.lang.String fieldName)
```
    Get an iterable value by field name, IllegalStateException is thrown if schema doesn't match.
  - getMap
```
@Nullable
public <T1,T2> java.util.Map<T1,T2> getMap(java.lang.String fieldName)
```
    Get a MAP value by field name, IllegalStateException is thrown if schema doesn't match.
  - getLogicalTypeValue
```
@Nullable
public <T> T getLogicalTypeValue(java.lang.String fieldName,
                                           java.lang.Class<T> clazz)
```
    Returns the Logical Type input type for this field. IllegalStateException is thrown if schema doesn't match.
  - getRow
```
@Nullable
public Row getRow(java.lang.String fieldName)
```
    Get a Schema.TypeName.ROW value by field name, IllegalStateException is thrown if schema doesn't match.
  - getByte
```
@Nullable
public java.lang.Byte getByte(int idx)
```
    Get a Schema.TypeName.BYTE value by field index, ClassCastException is thrown if schema doesn't match.
  - getBytes
```
@Nullable
public byte[] getBytes(int idx)
```
    Get a Schema.TypeName.BYTES value by field index, ClassCastException is thrown if schema doesn't match.
  - getInt16
```
@Nullable
public java.lang.Short getInt16(int idx)
```
    Get a Schema.TypeName.INT16 value by field index, ClassCastException is thrown if schema doesn't match.
  - getInt32
```
@Nullable
public java.lang.Integer getInt32(int idx)
```
    Get a Schema.TypeName.INT32 value by field index, ClassCastException is thrown if schema doesn't match.
  - getFloat
```
@Nullable
public java.lang.Float getFloat(int idx)
```
    Get a Schema.TypeName.FLOAT value by field index, ClassCastException is thrown if schema doesn't match.
  - getDouble
```
@Nullable
public java.lang.Double getDouble(int idx)
```
    Get a Schema.TypeName.DOUBLE value by field index, ClassCastException is thrown if schema doesn't match.
  - getInt64
```
@Nullable
public java.lang.Long getInt64(int idx)
```
    Get a Schema.TypeName.INT64 value by field index, ClassCastException is thrown if schema doesn't match.
  - getString
```
@Nullable
public java.lang.String getString(int idx)
```
    Get a String value by field index, ClassCastException is thrown if schema doesn't match.
  - getDateTime
```
@Nullable
public ReadableDateTime getDateTime(int idx)
```
    Get a Schema.TypeName.DATETIME value by field index, IllegalStateException is thrown if schema doesn't match.
  - getDecimal
```
@Nullable
public java.math.BigDecimal getDecimal(int idx)
```
    Get a BigDecimal value by field index, ClassCastException is thrown if schema doesn't match.
  - getBoolean
```
@Nullable
public java.lang.Boolean getBoolean(int idx)
```
    Get a Boolean value by field index, ClassCastException is thrown if schema doesn't match.
  - getArray
```
@Nullable
public <T> java.util.Collection<T> getArray(int idx)
```
    Get an array value by field index, IllegalStateException is thrown if schema doesn't match.
  - getIterable
```
@Nullable
public <T> java.lang.Iterable<T> getIterable(int idx)
```
    Get an iterable value by field index, IllegalStateException is thrown if schema doesn't match.
  - getMap
```
@Nullable
public <T1,T2> java.util.Map<T1,T2> getMap(int idx)
```
    Get a MAP value by field index, IllegalStateException is thrown if schema doesn't match.
  - getLogicalTypeValue
```
@Nullable
public <T> T getLogicalTypeValue(int idx,
                                           java.lang.Class<T> clazz)
```
    Returns the Logical Type input type for this field. IllegalStateException is thrown if schema doesn't match.
  - getRow
```
@Nullable
public Row getRow(int idx)
```
    Get a Row value by field index, IllegalStateException is thrown if schema doesn't match.
  - getSchema
```
public Schema getSchema()
```
    Return Schema which describes the fields.
  - equals
```
public boolean equals(java.lang.Object o)
```
    Overrides:
    
    equals in class java.lang.Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class java.lang.Object
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object
  - withSchema
```
public static Row.Builder withSchema(Schema schema)
```
    Creates a record builder with specified getSchema(). Row.Builder.build() will throw an IllegalArgumentException if number of fields in getSchema() does not match the number of fields specified.
  - toRow
```
public static <T> java.util.stream.Collector<T,java.util.List<java.lang.Object>,Row> toRow(Schema schema)
```
    Creates a Row from the list of values and getSchema().
  - nullRow
```
public static Row nullRow(Schema schema)
```
    Creates a new record filled with nulls.

Class Row

Nested Class Summary

Method Summary

Methods inherited from class java.lang.Object

Method Detail

getValue

getFieldCount

getValues

getValue

getByte

getBytes

getInt16

getInt32

getInt64

getDecimal

getFloat

getDouble

getString

getDateTime

getBoolean

getArray

getIterable

getMap

getLogicalTypeValue

getRow

getByte

getBytes

getInt16

getInt32

getFloat

getDouble

getInt64

getString

getDateTime

getDecimal

getBoolean

getArray

getIterable

getMap

getLogicalTypeValue

getRow

getSchema

equals

hashCode

toString

withSchema

toRow

nullRow