public class EsDataFrameWriter
extends org.elasticsearch.spark.rdd.EsRDDWriter<org.apache.spark.sql.Row>
| Constructor and Description |
|---|
EsDataFrameWriter(org.apache.spark.sql.types.StructType schema,
String serializedSettings) |
| Modifier and Type | Method and Description |
|---|---|
protected Class<? extends org.elasticsearch.hadoop.serialization.BytesConverter> |
bytesConverter() |
protected Class<? extends org.elasticsearch.hadoop.serialization.field.FieldExtractor> |
fieldExtractor() |
protected Object |
processData(scala.collection.Iterator<org.apache.spark.sql.Row> data) |
String |
serializedSettings() |
protected Class<? extends org.elasticsearch.hadoop.serialization.builder.ValueWriter<?>> |
valueWriter() |
public EsDataFrameWriter(org.apache.spark.sql.types.StructType schema,
String serializedSettings)
protected Class<? extends org.elasticsearch.hadoop.serialization.BytesConverter> bytesConverter()
bytesConverter in class org.elasticsearch.spark.rdd.EsRDDWriter<org.apache.spark.sql.Row>protected Class<? extends org.elasticsearch.hadoop.serialization.field.FieldExtractor> fieldExtractor()
fieldExtractor in class org.elasticsearch.spark.rdd.EsRDDWriter<org.apache.spark.sql.Row>protected Object processData(scala.collection.Iterator<org.apache.spark.sql.Row> data)
processData in class org.elasticsearch.spark.rdd.EsRDDWriter<org.apache.spark.sql.Row>public String serializedSettings()
serializedSettings in class org.elasticsearch.spark.rdd.EsRDDWriter<org.apache.spark.sql.Row>protected Class<? extends org.elasticsearch.hadoop.serialization.builder.ValueWriter<?>> valueWriter()
valueWriter in class org.elasticsearch.spark.rdd.EsRDDWriter<org.apache.spark.sql.Row>