public class SchemaUtils
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
SchemaUtils.Schema |
static class |
SchemaUtils.Schema$ |
| Constructor and Description |
|---|
SchemaUtils() |
| 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) |
public static SchemaUtils.Schema discoverMapping(Settings cfg)
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)
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)
public static void setRowInfo(Settings settings, org.apache.spark.sql.types.StructType struct)
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)
public static scala.Tuple2<java.util.Properties,java.util.Properties> detectRowInfo(Settings settings, org.apache.spark.sql.types.StructType struct)