org.apache.samza.sql

Class SamzaSqlRelRecord

java.lang.Object

org.apache.samza.sql.SamzaSqlRelRecord

All Implemented Interfaces:

java.io.Serializable

@InterfaceStability.Unstable
public class SamzaSqlRelRecord
extends java.lang.Object
implements java.io.Serializable

Samza sql relational record. A record consists of list of column values and the associated column names. A column value could be nested, meaning, it could be another SamzaSqlRelRecord. Right now we do not store any metadata (like nullability, etc) other than the column name in the SamzaSqlRelRecord.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SamzaSqlRelRecord(java.util.List<java.lang.String> fieldNames, java.util.List<java.lang.Object> fieldValues) Creates a SamzaSqlRelRecord from the list of relational fields and values.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
java.util.Optional<java.lang.Object>	getField(java.lang.String name) Get the value of the field corresponding to the field name.
java.util.List<java.lang.String>	getFieldNames() Get the field names of all the columns in the relational message.
java.util.List<java.lang.Object>	getFieldValues() Get the field values of all the columns in the relational message.
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

SamzaSqlRelRecord

public SamzaSqlRelRecord(java.util.List<java.lang.String> fieldNames,
                         java.util.List<java.lang.Object> fieldValues)

Creates a SamzaSqlRelRecord from the list of relational fields and values.

Parameters:

fieldNames - Ordered list of field names in the row.

fieldValues - Ordered list of all the values in the row. Some of the fields can be null. This could be result of delete change capture event in the stream or because of the result of the outer join or the fields themselves are null in the original stream.

Method Detail

getFieldNames

public java.util.List<java.lang.String> getFieldNames()

Get the field names of all the columns in the relational message.

Returns:

the field names of all columns.

getFieldValues

public java.util.List<java.lang.Object> getFieldValues()

Get the field values of all the columns in the relational message.

Returns:

the field values of all columns.

getField

public java.util.Optional<java.lang.Object> getField(java.lang.String name)

Get the value of the field corresponding to the field name.

Parameters:

name - Name of the field.

Returns:

returns the value of the field.

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object