org.elasticsearch.spark.sql

Class ScalaRowValueReader

java.lang.Object

org.elasticsearch.spark.serialization.ScalaValueReader

org.elasticsearch.spark.sql.ScalaRowValueReader

All Implemented Interfaces:

org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback, org.elasticsearch.hadoop.serialization.SettingsAware, RowValueReader

public class ScalaRowValueReader
extends org.elasticsearch.spark.serialization.ScalaValueReader
implements RowValueReader, org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

Constructor Summary

Constructors

Constructor and Description
ScalaRowValueReader()

Method Summary

Modifier and Type	Method and Description
java.lang.Object	addToArray(java.lang.Object array, java.util.List<java.lang.Object> values)
void	addToMap(java.lang.Object map, java.lang.Object key, java.lang.Object value)
protected java.util.Set<java.lang.String>	arrayFields()
void	beginDoc()
void	beginGeoField()
void	beginLeadMetadata()
void	beginSource()
void	beginTrailMetadata()
java.lang.Object	createArray(org.elasticsearch.hadoop.serialization.FieldType typ)
java.sql.Timestamp	createDate(long value)
java.lang.Object	createMap()
scala.collection.immutable.Seq<java.lang.String>	currentArrayRowOrder()
protected boolean	currentFieldIsGeo()
void	endDoc()
void	endGeoField()
void	endLeadMetadata()
void	endSource()
void	endTrailMetadata()
void	excludeSource()
boolean	inArray()
java.lang.String	metadataField()
boolean	metadataMap()
protected boolean	readMetadata()
java.lang.Object	readValue(org.elasticsearch.hadoop.serialization.Parser parser, java.lang.String value, org.elasticsearch.hadoop.serialization.FieldType esType)
boolean	rootLevel()
protected scala.collection.Map<java.lang.String,scala.collection.immutable.Seq<java.lang.String>>	rowColumnsMap()
protected java.lang.String	sparkRowField()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.spark.sql.RowValueReader

addToBuffer, rowColumns, setSettings

Constructor Detail

ScalaRowValueReader

public ScalaRowValueReader()

Method Detail

addToArray

public java.lang.Object addToArray(java.lang.Object array,
                                   java.util.List<java.lang.Object> values)

addToMap

public void addToMap(java.lang.Object map,
                     java.lang.Object key,
                     java.lang.Object value)

arrayFields

protected java.util.Set<java.lang.String> arrayFields()

Specified by:

arrayFields in interface RowValueReader

beginDoc

public void beginDoc()

Specified by:

beginDoc in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

beginGeoField

public void beginGeoField()

Specified by:

beginGeoField in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

beginLeadMetadata

public void beginLeadMetadata()

Specified by:

beginLeadMetadata in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

beginSource

public void beginSource()

Specified by:

beginSource in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

beginTrailMetadata

public void beginTrailMetadata()

Specified by:

beginTrailMetadata in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

createArray

public java.lang.Object createArray(org.elasticsearch.hadoop.serialization.FieldType typ)

createDate

public java.sql.Timestamp createDate(long value)

createMap

public java.lang.Object createMap()

currentArrayRowOrder

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

currentFieldIsGeo

protected boolean currentFieldIsGeo()

Specified by:

currentFieldIsGeo in interface RowValueReader

endDoc

public void endDoc()

Specified by:

endDoc in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

endGeoField

public void endGeoField()

Specified by:

endGeoField in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

endLeadMetadata

public void endLeadMetadata()

Specified by:

endLeadMetadata in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

endSource

public void endSource()

Specified by:

endSource in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

endTrailMetadata

public void endTrailMetadata()

Specified by:

endTrailMetadata in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

excludeSource

public void excludeSource()

Specified by:

excludeSource in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback

inArray

public boolean inArray()

metadataField

public java.lang.String metadataField()

Specified by:

metadataField in interface RowValueReader

metadataMap

public boolean metadataMap()

readMetadata

protected boolean readMetadata()

Specified by:

readMetadata in interface RowValueReader

readValue

public java.lang.Object readValue(org.elasticsearch.hadoop.serialization.Parser parser,
                                  java.lang.String value,
                                  org.elasticsearch.hadoop.serialization.FieldType esType)

rootLevel

public boolean rootLevel()

rowColumnsMap

protected scala.collection.Map<java.lang.String,scala.collection.immutable.Seq<java.lang.String>> rowColumnsMap()

Specified by:

rowColumnsMap in interface RowValueReader

sparkRowField

protected java.lang.String sparkRowField()

Specified by:

sparkRowField in interface RowValueReader