org.elasticsearch.spark.sql

Class ScalaEsRow

java.lang.Object

org.elasticsearch.spark.sql.ScalaEsRow

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.sql.Row

public class ScalaEsRow
extends java.lang.Object
implements org.apache.spark.sql.Row

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ScalaEsRow() No-arg constructor for Kryo serialization.
ScalaEsRow(scala.collection.immutable.Seq<java.lang.String> rowOrder)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	apply(int i)
ScalaEsRow	copy()
java.lang.Object	get(int i)
boolean	getBoolean(int i)
byte	getByte(int i)
double	getDouble(int i)
float	getFloat(int i)
int	getInt(int i)
long	getLong(int i)
short	getShort(int i)
java.lang.String	getString(int i)
boolean	isNullAt(int i)
scala.collection.Iterator<java.lang.Object>	iterator()
int	length()
scala.collection.immutable.Seq<java.lang.String>	rowOrder()
scala.collection.immutable.Seq<java.lang.Object>	toSeq()
scala.collection.mutable.ArrayBuffer<java.lang.Object>	values()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.spark.sql.Row

$init$, anyNull, empty, equals, fieldIndex, fromSeq, fromTuple, getAs, getAs, getDate, getDecimal, getInstant, getJavaMap, getList, getLocalDate, getMap, getSeq, getStruct, getTimestamp, getValuesMap, hashCode, json, jsonValue, merge, mkString, mkString, mkString, prettyJson, schema, size, toString, unapplySeq

Constructor Detail

ScalaEsRow

public ScalaEsRow(scala.collection.immutable.Seq<java.lang.String> rowOrder)

ScalaEsRow

public ScalaEsRow()

No-arg constructor for Kryo serialization.

Method Detail

apply

public java.lang.Object apply(int i)

Specified by:

apply in interface org.apache.spark.sql.Row

copy

public ScalaEsRow copy()

Specified by:

copy in interface org.apache.spark.sql.Row

get

public java.lang.Object get(int i)

Specified by:

get in interface org.apache.spark.sql.Row

getBoolean

public boolean getBoolean(int i)

Specified by:

getBoolean in interface org.apache.spark.sql.Row

getByte

public byte getByte(int i)

Specified by:

getByte in interface org.apache.spark.sql.Row

getDouble

public double getDouble(int i)

Specified by:

getDouble in interface org.apache.spark.sql.Row

getFloat

public float getFloat(int i)

Specified by:

getFloat in interface org.apache.spark.sql.Row

getInt

public int getInt(int i)

Specified by:

getInt in interface org.apache.spark.sql.Row

getLong

public long getLong(int i)

Specified by:

getLong in interface org.apache.spark.sql.Row

getShort

public short getShort(int i)

Specified by:

getShort in interface org.apache.spark.sql.Row

getString

public java.lang.String getString(int i)

Specified by:

getString in interface org.apache.spark.sql.Row

isNullAt

public boolean isNullAt(int i)

Specified by:

isNullAt in interface org.apache.spark.sql.Row

iterator

public scala.collection.Iterator<java.lang.Object> iterator()

length

public int length()

Specified by:

length in interface org.apache.spark.sql.Row

rowOrder

public scala.collection.immutable.Seq<java.lang.String> rowOrder()

toSeq

public scala.collection.immutable.Seq<java.lang.Object> toSeq()

Specified by:

toSeq in interface org.apache.spark.sql.Row

values

public scala.collection.mutable.ArrayBuffer<java.lang.Object> values()