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

Constructor Summary

Constructors

Constructor and Description
JavaEsSparkStreaming()

Method Summary

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

Constructor Detail

JavaEsSparkStreaming

public JavaEsSparkStreaming()

Method Detail

saveToEs

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

saveToEs

public static 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 static void saveToEs(org.apache.spark.streaming.api.java.JavaDStream<?> ds,
                            java.util.Map<java.lang.String,java.lang.String> cfg)

saveToEsWithMeta

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

saveToEsWithMeta

public static <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 static <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 static void saveJsonToEs(org.apache.spark.streaming.api.java.JavaDStream<java.lang.String> ds,
                                java.lang.String resource)

saveJsonToEs

public static 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 static 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 static void saveJsonByteArrayToEs(org.apache.spark.streaming.api.java.JavaDStream<byte[]> ds,
                                         java.lang.String resource)

saveJsonByteArrayToEs

public static 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 static void saveJsonByteArrayToEs(org.apache.spark.streaming.api.java.JavaDStream<byte[]> ds,
                                         java.util.Map<java.lang.String,java.lang.String> cfg)