org.elasticsearch.spark.sql

Class SchemaUtils

java.lang.Object

org.elasticsearch.spark.sql.SchemaUtils

public class SchemaUtils
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SchemaUtils.Schema
static class	SchemaUtils.Schema$

Constructor Summary

Constructors

Constructor and Description
SchemaUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.spark.sql.types.StructType	convertToStruct(org.elasticsearch.hadoop.serialization.dto.mapping.Mapping mapping, java.util.Map<java.lang.String,org.elasticsearch.hadoop.serialization.dto.mapping.GeoField> geoInfo, Settings cfg)
static scala.Tuple2<java.util.Properties,java.util.Properties>	detectRowInfo(Settings settings, org.apache.spark.sql.types.StructType struct)
static SchemaUtils.Schema	discoverMapping(Settings cfg)
static scala.Tuple2<org.elasticsearch.hadoop.serialization.dto.mapping.Mapping,java.util.Map<java.lang.String,org.elasticsearch.hadoop.serialization.dto.mapping.GeoField>>	discoverMappingAndGeoFields(Settings cfg)
static scala.Tuple2<scala.collection.mutable.LinkedHashMap<java.lang.String,scala.collection.immutable.Seq<java.lang.String>>,java.util.LinkedHashSet<java.lang.String>>	getRowInfo(Settings settings)
static void	setRowInfo(Settings settings, org.apache.spark.sql.types.StructType struct)

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaUtils

public SchemaUtils()

Method Detail

discoverMapping

public static SchemaUtils.Schema discoverMapping(Settings cfg)

discoverMappingAndGeoFields

public static scala.Tuple2<org.elasticsearch.hadoop.serialization.dto.mapping.Mapping,java.util.Map<java.lang.String,org.elasticsearch.hadoop.serialization.dto.mapping.GeoField>> discoverMappingAndGeoFields(Settings cfg)

convertToStruct

public static org.apache.spark.sql.types.StructType convertToStruct(org.elasticsearch.hadoop.serialization.dto.mapping.Mapping mapping,
                                                                    java.util.Map<java.lang.String,org.elasticsearch.hadoop.serialization.dto.mapping.GeoField> geoInfo,
                                                                    Settings cfg)

setRowInfo

public static void setRowInfo(Settings settings,
                              org.apache.spark.sql.types.StructType struct)

getRowInfo

public static scala.Tuple2<scala.collection.mutable.LinkedHashMap<java.lang.String,scala.collection.immutable.Seq<java.lang.String>>,java.util.LinkedHashSet<java.lang.String>> getRowInfo(Settings settings)

detectRowInfo

public static scala.Tuple2<java.util.Properties,java.util.Properties> detectRowInfo(Settings settings,
                                                                                    org.apache.spark.sql.types.StructType struct)