org.elasticsearch.spark.sql

Class DefaultSource

java.lang.Object

org.elasticsearch.spark.sql.DefaultSource

All Implemented Interfaces:

org.apache.spark.sql.sources.CreatableRelationProvider, org.apache.spark.sql.sources.RelationProvider, org.apache.spark.sql.sources.SchemaRelationProvider, org.apache.spark.sql.sources.StreamSinkProvider

Direct Known Subclasses:

DefaultSource15

public class DefaultSource
extends java.lang.Object
implements org.apache.spark.sql.sources.RelationProvider, org.apache.spark.sql.sources.SchemaRelationProvider, org.apache.spark.sql.sources.CreatableRelationProvider, org.apache.spark.sql.sources.StreamSinkProvider

Constructor Summary

Constructors

Constructor and Description
DefaultSource()

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.sources.BaseRelation	createRelation(org.apache.spark.sql.SQLContext sqlContext, scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters)
org.apache.spark.sql.sources.BaseRelation	createRelation(org.apache.spark.sql.SQLContext sqlContext, scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters, org.apache.spark.sql.types.StructType schema)
org.apache.spark.sql.sources.BaseRelation	createRelation(org.apache.spark.sql.SQLContext sqlContext, org.apache.spark.sql.SaveMode mode, scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> data)
org.apache.spark.sql.execution.streaming.Sink	createSink(org.apache.spark.sql.SQLContext sqlContext, scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters, scala.collection.immutable.Seq<java.lang.String> partitionColumns, org.apache.spark.sql.streaming.OutputMode outputMode)
scala.collection.immutable.Map<java.lang.String,java.lang.String>	params(scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSource

public DefaultSource()

Method Detail

createRelation

public org.apache.spark.sql.sources.BaseRelation createRelation(org.apache.spark.sql.SQLContext sqlContext,
                                                                scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters)

Specified by:

createRelation in interface org.apache.spark.sql.sources.RelationProvider

createRelation

public org.apache.spark.sql.sources.BaseRelation createRelation(org.apache.spark.sql.SQLContext sqlContext,
                                                                scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters,
                                                                org.apache.spark.sql.types.StructType schema)

Specified by:

createRelation in interface org.apache.spark.sql.sources.SchemaRelationProvider

createRelation

public org.apache.spark.sql.sources.BaseRelation createRelation(org.apache.spark.sql.SQLContext sqlContext,
                                                                org.apache.spark.sql.SaveMode mode,
                                                                scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters,
                                                                org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> data)

Specified by:

createRelation in interface org.apache.spark.sql.sources.CreatableRelationProvider

createSink

public org.apache.spark.sql.execution.streaming.Sink createSink(org.apache.spark.sql.SQLContext sqlContext,
                                                                scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters,
                                                                scala.collection.immutable.Seq<java.lang.String> partitionColumns,
                                                                org.apache.spark.sql.streaming.OutputMode outputMode)

Specified by:

createSink in interface org.apache.spark.sql.sources.StreamSinkProvider

params

public scala.collection.immutable.Map<java.lang.String,java.lang.String> params(scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters)