public class EsDataFrameWriter extends 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() |
log, metadataExtractor, metaExtractor, runtimeMetadata, settings, userProvider, writepublic EsDataFrameWriter(StructType schema, String serializedSettings)
protected Class<? extends org.elasticsearch.hadoop.serialization.BytesConverter> bytesConverter()
bytesConverter in class EsRDDWriter<Row>protected Class<? extends org.elasticsearch.hadoop.serialization.field.FieldExtractor> fieldExtractor()
fieldExtractor in class EsRDDWriter<Row>protected Object processData(scala.collection.Iterator<Row> data)
processData in class EsRDDWriter<Row>public String serializedSettings()
serializedSettings in class EsRDDWriter<Row>protected Class<? extends org.elasticsearch.hadoop.serialization.builder.ValueWriter<?>> valueWriter()
valueWriter in class EsRDDWriter<Row>