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