Row (Apache Beam 2.5.0)

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

All Implemented Interfaces:

java.io.Serializable
```
@Experimental
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.

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

Constructor Summary

Constructors
Constructor and Description

Row()

Constructors
Constructor and Description
`Row()`

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.List<T>`	`getArray(int idx)` Get an array value by field index, `IllegalStateException` is thrown if schema doesn't match.
`<T> java.util.List<T>`	`getArray(java.lang.String fieldName)` Get an array value by field name, `IllegalStateException` is thrown if schema doesn't match.
`boolean`	`getBoolean(int idx)` Get a `Boolean` value by field index, `ClassCastException` is thrown if schema doesn't match.
`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.
`byte`	`getByte(java.lang.String fieldName)` Get a `Schema.TypeName.BYTE` 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.
`double`	`getDouble(java.lang.String fieldName)` Get a `Schema.TypeName.DOUBLE` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`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.
`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.
`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.
`int`	`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.
`long`	`getInt64(java.lang.String fieldName)` Get a `Schema.TypeName.INT64` value by field name, `IllegalStateException` is thrown if schema doesn't match.
`<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.
`abstract 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.
`<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()`.
`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, toString, wait, wait, wait

- Constructor Detail
  - Row
```
public Row()
```
- Method Detail
  - 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.
  - getValue
```
public <T> T getValue(java.lang.String fieldName)
```
    Get value by field name, ClassCastException is thrown if type doesn't match.
  - getValue
```
@Nullable
public <T> T getValue(int fieldIdx)
```
    Get value by field index, ClassCastException is thrown if schema doesn't match.
  - getByte
```
public byte getByte(java.lang.String fieldName)
```
    Get a Schema.TypeName.BYTE value by field name, IllegalStateException is thrown if schema doesn't match.
  - getInt16
```
public short getInt16(java.lang.String fieldName)
```
    Get a Schema.TypeName.INT16 value by field name, IllegalStateException is thrown if schema doesn't match.
  - getInt32
```
public int getInt32(java.lang.String fieldName)
```
    Get a Schema.TypeName.INT32 value by field name, IllegalStateException is thrown if schema doesn't match.
  - getInt64
```
public long getInt64(java.lang.String fieldName)
```
    Get a Schema.TypeName.INT64 value by field name, IllegalStateException is thrown if schema doesn't match.
  - getDecimal
```
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
```
public float getFloat(java.lang.String fieldName)
```
    Get a Schema.TypeName.FLOAT value by field name, IllegalStateException is thrown if schema doesn't match.
  - getDouble
```
public double getDouble(java.lang.String fieldName)
```
    Get a Schema.TypeName.DOUBLE value by field name, IllegalStateException is thrown if schema doesn't match.
  - getString
```
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
```
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
```
public boolean getBoolean(java.lang.String fieldName)
```
    Get a Schema.TypeName.BOOLEAN value by field name, IllegalStateException is thrown if schema doesn't match.
  - getArray
```
public <T> java.util.List<T> getArray(java.lang.String fieldName)
```
    Get an array value by field name, IllegalStateException is thrown if schema doesn't match.
  - getMap
```
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.
  - getRow
```
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
```
public java.lang.Byte getByte(int idx)
```
    Get a Schema.TypeName.BYTE value by field index, ClassCastException is thrown if schema doesn't match.
  - getInt16
```
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
```
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
```
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
```
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
```
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
```
public java.lang.String getString(int idx)
```
    Get a String value by field index, ClassCastException is thrown if schema doesn't match.
  - getDateTime
```
public ReadableDateTime getDateTime(int idx)
```
    Get a Schema.TypeName.DATETIME value by field index, IllegalStateException is thrown if schema doesn't match.
  - getDecimal
```
public java.math.BigDecimal getDecimal(int idx)
```
    Get a BigDecimal value by field index, ClassCastException is thrown if schema doesn't match.
  - getBoolean
```
public boolean getBoolean(int idx)
```
    Get a Boolean value by field index, ClassCastException is thrown if schema doesn't match.
  - getArray
```
public <T> java.util.List<T> getArray(int idx)
```
    Get an array value by field index, IllegalStateException is thrown if schema doesn't match.
  - getMap
```
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.
  - getRow
```
public Row getRow(int idx)
```
    Get a Row value by field index, IllegalStateException is thrown if schema doesn't match.
  - getFieldCount
```
public int getFieldCount()
```
    Return the size of data fields.
  - getValues
```
public abstract java.util.List<java.lang.Object> getValues()
```
    Return the list of data values.
  - getSchema
```
public abstract 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
  - 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.

Class Row

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Row

Method Detail

toRow

nullRow

getValue

getValue

getByte

getInt16

getInt32

getInt64

getDecimal

getFloat

getDouble

getString

getDateTime

getBoolean

getArray

getMap

getRow

getByte

getInt16

getInt32

getFloat

getDouble

getInt64

getString

getDateTime

getDecimal

getBoolean

getArray

getMap

getRow

getFieldCount

getValues

getSchema

equals

hashCode

withSchema