public class ElasticsearchRelation extends BaseRelation implements PrunedFilteredScan, InsertableRelation, scala.Product, scala.Serializable
| Constructor and Description |
|---|
ElasticsearchRelation(scala.collection.immutable.Map<String,String> parameters,
SQLContext sqlContext,
scala.Option<StructType> userSchema) |
| Modifier and Type | Method and Description |
|---|---|
abstract static R |
apply(T1 v1,
T2 v2,
T3 v3) |
RDD<Row> |
buildScan() |
RDD<Row> |
buildScan(String[] requiredColumns) |
ScalaEsRowRDD |
buildScan(String[] requiredColumns,
Filter[] filters) |
Settings |
cfg() |
void |
insert(Dataset<Row> data,
boolean overwrite) |
boolean |
isEmpty() |
SchemaUtils.Schema |
lazySchema() |
scala.collection.immutable.Map<String,String> |
parameters() |
StructType |
schema() |
SQLContext |
sqlContext() |
static String |
toString() |
Filter[] |
unhandledFilters(Filter[] filters) |
scala.Option<StructType> |
userSchema() |
ScalaValueWriter |
valueWriter() |
needConversion, sizeInBytesclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic ElasticsearchRelation(scala.collection.immutable.Map<String,String> parameters, SQLContext sqlContext, scala.Option<StructType> userSchema)
public abstract static R apply(T1 v1,
T2 v2,
T3 v3)
public static String toString()
public SQLContext sqlContext()
sqlContext in class BaseRelationpublic scala.Option<StructType> userSchema()
public Settings cfg()
public SchemaUtils.Schema lazySchema()
public ScalaValueWriter valueWriter()
public StructType schema()
schema in class BaseRelationpublic ScalaEsRowRDD buildScan(String[] requiredColumns, Filter[] filters)
buildScan in interface PrunedFilteredScanpublic Filter[] unhandledFilters(Filter[] filters)
unhandledFilters in class BaseRelationpublic void insert(Dataset<Row> data, boolean overwrite)
insert in interface InsertableRelationpublic boolean isEmpty()