public class EsDataFrameWriter
extends <any>
| Constructor and Description |
|---|
EsDataFrameWriter(org.apache.spark.sql.types.StructType schema,
java.lang.String serializedSettings) |
| 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() |
public EsDataFrameWriter(org.apache.spark.sql.types.StructType schema,
java.lang.String serializedSettings)
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)
public java.lang.String serializedSettings()
protected java.lang.Class<? extends org.elasticsearch.hadoop.serialization.builder.ValueWriter<?>> valueWriter()