public class SchemaUtils extends 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,
Map<String,org.elasticsearch.hadoop.serialization.dto.mapping.GeoField> geoInfo,
Settings cfg) |
static scala.Tuple2<Properties,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,Map<String,org.elasticsearch.hadoop.serialization.dto.mapping.GeoField>> |
discoverMappingAndGeoFields(Settings cfg) |
static scala.Tuple2<scala.collection.mutable.LinkedHashMap<String,scala.collection.immutable.Seq<String>>,LinkedHashSet<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,Map<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,
Map<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<String,scala.collection.immutable.Seq<String>>,LinkedHashSet<String>> getRowInfo(Settings settings)
public static scala.Tuple2<Properties,Properties> detectRowInfo(Settings settings, org.apache.spark.sql.types.StructType struct)