org.elasticsearch.spark.sql

Class EsDataFrameWriter

java.lang.Object

<any>

org.elasticsearch.spark.sql.EsDataFrameWriter

public class EsDataFrameWriter
extends <any>

Constructor Summary

Constructors

Constructor and Description
EsDataFrameWriter(org.apache.spark.sql.types.StructType schema, java.lang.String serializedSettings)

Method Summary

Modifier and Type	Method and Description
protected java.lang.Class<? extends org.elasticsearch.hadoop.serialization.BytesConverter>	bytesConverter()
protected java.lang.Class<? extends org.elasticsearch.hadoop.serialization.field.FieldExtractor>	fieldExtractor()
protected java.lang.Object	processData(scala.collection.Iterator<org.apache.spark.sql.Row> data)
java.lang.String	serializedSettings()
protected java.lang.Class<? extends org.elasticsearch.hadoop.serialization.builder.ValueWriter<?>>	valueWriter()

Methods inherited from class java.lang.Object

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

Constructor Detail

EsDataFrameWriter

public EsDataFrameWriter(org.apache.spark.sql.types.StructType schema,
                         java.lang.String serializedSettings)

Method Detail

bytesConverter

protected java.lang.Class<? extends org.elasticsearch.hadoop.serialization.BytesConverter> bytesConverter()

fieldExtractor

protected java.lang.Class<? extends org.elasticsearch.hadoop.serialization.field.FieldExtractor> fieldExtractor()

processData

protected java.lang.Object processData(scala.collection.Iterator<org.apache.spark.sql.Row> data)

serializedSettings

public java.lang.String serializedSettings()

valueWriter

protected java.lang.Class<? extends org.elasticsearch.hadoop.serialization.builder.ValueWriter<?>> valueWriter()