org.elasticsearch.spark.streaming.api.java

Class JavaEsSparkStreaming$

java.lang.Object

org.elasticsearch.spark.streaming.api.java.JavaEsSparkStreaming$

public class JavaEsSparkStreaming$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static JavaEsSparkStreaming$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
JavaEsSparkStreaming$()

Method Summary

Modifier and Type	Method and Description
void	saveJsonByteArrayToEs(org.apache.spark.streaming.api.java.JavaDStream<byte[]> ds, java.util.Map<java.lang.String,java.lang.String> cfg)
void	saveJsonByteArrayToEs(org.apache.spark.streaming.api.java.JavaDStream<byte[]> ds, java.lang.String resource)
void	saveJsonByteArrayToEs(org.apache.spark.streaming.api.java.JavaDStream<byte[]> ds, java.lang.String resource, java.util.Map<java.lang.String,java.lang.String> cfg)
void	saveJsonToEs(org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> ds, java.util.Map<java.lang.String,java.lang.String> cfg)
void	saveJsonToEs(org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> ds, java.lang.String resource)
void	saveJsonToEs(org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> ds, java.lang.String resource, java.util.Map<java.lang.String,java.lang.String> cfg)
void	saveToEs(org.apache.spark.streaming.api.java.JavaDStream<?> ds, java.util.Map<java.lang.String,java.lang.String> cfg)
void	saveToEs(org.apache.spark.streaming.api.java.JavaDStream<?> ds, java.lang.String resource)
void	saveToEs(org.apache.spark.streaming.api.java.JavaDStream<?> ds, java.lang.String resource, java.util.Map<java.lang.String,java.lang.String> cfg)
<K,V> void	saveToEsWithMeta(org.apache.spark.streaming.api.java.JavaPairDStream<K,V> ds, java.util.Map<java.lang.String,java.lang.String> cfg)
<K,V> void	saveToEsWithMeta(org.apache.spark.streaming.api.java.JavaPairDStream<K,V> ds, java.lang.String resource)
<K,V> void	saveToEsWithMeta(org.apache.spark.streaming.api.java.JavaPairDStream<K,V> ds, java.lang.String resource, java.util.Map<java.lang.String,java.lang.String> cfg)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final JavaEsSparkStreaming$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

JavaEsSparkStreaming$

public JavaEsSparkStreaming$()

Method Detail

saveToEs

public void saveToEs(org.apache.spark.streaming.api.java.JavaDStream<?> ds,
                     java.lang.String resource)

saveToEs

public void saveToEs(org.apache.spark.streaming.api.java.JavaDStream<?> ds,
                     java.lang.String resource,
                     java.util.Map<java.lang.String,java.lang.String> cfg)

saveToEs

public void saveToEs(org.apache.spark.streaming.api.java.JavaDStream<?> ds,
                     java.util.Map<java.lang.String,java.lang.String> cfg)

saveToEsWithMeta

public <K,V> void saveToEsWithMeta(org.apache.spark.streaming.api.java.JavaPairDStream<K,V> ds,
                                   java.lang.String resource)

saveToEsWithMeta

public <K,V> void saveToEsWithMeta(org.apache.spark.streaming.api.java.JavaPairDStream<K,V> ds,
                                   java.lang.String resource,
                                   java.util.Map<java.lang.String,java.lang.String> cfg)

saveToEsWithMeta

public <K,V> void saveToEsWithMeta(org.apache.spark.streaming.api.java.JavaPairDStream<K,V> ds,
                                   java.util.Map<java.lang.String,java.lang.String> cfg)

saveJsonToEs

public void saveJsonToEs(org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> ds,
                         java.lang.String resource)

saveJsonToEs

public void saveJsonToEs(org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> ds,
                         java.lang.String resource,
                         java.util.Map<java.lang.String,java.lang.String> cfg)

saveJsonToEs

public void saveJsonToEs(org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> ds,
                         java.util.Map<java.lang.String,java.lang.String> cfg)

saveJsonByteArrayToEs

public void saveJsonByteArrayToEs(org.apache.spark.streaming.api.java.JavaDStream<byte[]> ds,
                                  java.lang.String resource)

saveJsonByteArrayToEs

public void saveJsonByteArrayToEs(org.apache.spark.streaming.api.java.JavaDStream<byte[]> ds,
                                  java.lang.String resource,
                                  java.util.Map<java.lang.String,java.lang.String> cfg)

saveJsonByteArrayToEs

public void saveJsonByteArrayToEs(org.apache.spark.streaming.api.java.JavaDStream<byte[]> ds,
                                  java.util.Map<java.lang.String,java.lang.String> cfg)