org.elasticsearch.spark.sql

Interface RowValueReader

All Superinterfaces:

org.elasticsearch.hadoop.serialization.SettingsAware

All Known Implementing Classes:

ScalaRowValueReader

public interface RowValueReader
extends org.elasticsearch.hadoop.serialization.SettingsAware

Method Summary

Modifier and Type	Method and Description
void	addToBuffer(ScalaEsRow esRow, java.lang.Object key, java.lang.Object value)
java.util.Set<java.lang.String>	arrayFields()
boolean	currentFieldIsGeo()
java.lang.String	metadataField()
boolean	readMetadata()
scala.collection.immutable.Seq<java.lang.String>	rowColumns(java.lang.String currentField)
scala.collection.Map<java.lang.String,scala.collection.immutable.Seq<java.lang.String>>	rowColumnsMap()
void	setSettings(Settings settings)
java.lang.String	sparkRowField()

Method Detail

addToBuffer

void addToBuffer(ScalaEsRow esRow,
                 java.lang.Object key,
                 java.lang.Object value)

arrayFields

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

currentFieldIsGeo

boolean currentFieldIsGeo()

metadataField

java.lang.String metadataField()

readMetadata

boolean readMetadata()

rowColumns

scala.collection.immutable.Seq<java.lang.String> rowColumns(java.lang.String currentField)

rowColumnsMap

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

setSettings

void setSettings(Settings settings)

Specified by:

setSettings in interface org.elasticsearch.hadoop.serialization.SettingsAware

sparkRowField

java.lang.String sparkRowField()