public class JavaPairReceiverInputDStream<K,V> extends JavaPairInputDStream<K,V>
ReceiverInputDStream
, the
abstract class for defining any input stream that receives data over the network.Constructor and Description |
---|
JavaPairReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream,
scala.reflect.ClassTag<K> kClassTag,
scala.reflect.ClassTag<V> vClassTag) |
Modifier and Type | Method and Description |
---|---|
static JavaPairDStream<K,V> |
cache() |
static DStream<T> |
checkpoint(Duration interval) |
static scala.reflect.ClassTag<scala.Tuple2<K,V>> |
classTag() |
static <W> JavaPairDStream<K,scala.Tuple2<java.lang.Iterable<V>,java.lang.Iterable<W>>> |
cogroup(JavaPairDStream<K,W> other) |
static <W> JavaPairDStream<K,scala.Tuple2<java.lang.Iterable<V>,java.lang.Iterable<W>>> |
cogroup(JavaPairDStream<K,W> other,
int numPartitions) |
static <W> JavaPairDStream<K,scala.Tuple2<java.lang.Iterable<V>,java.lang.Iterable<W>>> |
cogroup(JavaPairDStream<K,W> other,
Partitioner partitioner) |
static <C> JavaPairDStream<K,C> |
combineByKey(Function<V,C> createCombiner,
Function2<C,V,C> mergeValue,
Function2<C,C,C> mergeCombiners,
Partitioner partitioner) |
static <C> JavaPairDStream<K,C> |
combineByKey(Function<V,C> createCombiner,
Function2<C,V,C> mergeValue,
Function2<C,C,C> mergeCombiners,
Partitioner partitioner,
boolean mapSideCombine) |
static JavaPairRDD<K,V> |
compute(Time validTime) |
static StreamingContext |
context() |
static JavaDStream<java.lang.Long> |
count() |
static JavaPairDStream<T,java.lang.Long> |
countByValue() |
static JavaPairDStream<T,java.lang.Long> |
countByValue(int numPartitions) |
static JavaPairDStream<T,java.lang.Long> |
countByValueAndWindow(Duration windowDuration,
Duration slideDuration) |
static JavaPairDStream<T,java.lang.Long> |
countByValueAndWindow(Duration windowDuration,
Duration slideDuration,
int numPartitions) |
static JavaDStream<java.lang.Long> |
countByWindow(Duration windowDuration,
Duration slideDuration) |
static DStream<scala.Tuple2<K,V>> |
dstream() |
static JavaPairDStream<K,V> |
filter(Function<scala.Tuple2<K,V>,java.lang.Boolean> f) |
static <U> JavaDStream<U> |
flatMap(FlatMapFunction<T,U> f) |
static <K2,V2> JavaPairDStream<K2,V2> |
flatMapToPair(PairFlatMapFunction<T,K2,V2> f) |
static <U> JavaPairDStream<K,U> |
flatMapValues(Function<V,java.lang.Iterable<U>> f) |
static void |
foreachRDD(VoidFunction<R> foreachFunc) |
static void |
foreachRDD(VoidFunction2<R,Time> foreachFunc) |
static <K,V> JavaPairReceiverInputDStream<K,V> |
fromReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream,
scala.reflect.ClassTag<K> evidence$1,
scala.reflect.ClassTag<V> evidence$2)
Convert a scala
ReceiverInputDStream to a Java-friendly
JavaReceiverInputDStream . |
static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,Optional<W>>> |
fullOuterJoin(JavaPairDStream<K,W> other) |
static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,Optional<W>>> |
fullOuterJoin(JavaPairDStream<K,W> other,
int numPartitions) |
static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,Optional<W>>> |
fullOuterJoin(JavaPairDStream<K,W> other,
Partitioner partitioner) |
static JavaDStream<java.util.List<T>> |
glom() |
static JavaPairDStream<K,java.lang.Iterable<V>> |
groupByKey() |
static JavaPairDStream<K,java.lang.Iterable<V>> |
groupByKey(int numPartitions) |
static JavaPairDStream<K,java.lang.Iterable<V>> |
groupByKey(Partitioner partitioner) |
static JavaPairDStream<K,java.lang.Iterable<V>> |
groupByKeyAndWindow(Duration windowDuration) |
static JavaPairDStream<K,java.lang.Iterable<V>> |
groupByKeyAndWindow(Duration windowDuration,
Duration slideDuration) |
static JavaPairDStream<K,java.lang.Iterable<V>> |
groupByKeyAndWindow(Duration windowDuration,
Duration slideDuration,
int numPartitions) |
static JavaPairDStream<K,java.lang.Iterable<V>> |
groupByKeyAndWindow(Duration windowDuration,
Duration slideDuration,
Partitioner partitioner) |
static InputDStream<scala.Tuple2<K,V>> |
inputDStream() |
static <W> JavaPairDStream<K,scala.Tuple2<V,W>> |
join(JavaPairDStream<K,W> other) |
static <W> JavaPairDStream<K,scala.Tuple2<V,W>> |
join(JavaPairDStream<K,W> other,
int numPartitions) |
static <W> JavaPairDStream<K,scala.Tuple2<V,W>> |
join(JavaPairDStream<K,W> other,
Partitioner partitioner) |
scala.reflect.ClassTag<K> |
kClassTag() |
static scala.reflect.ClassTag<K> |
kManifest() |
static <W> JavaPairDStream<K,scala.Tuple2<V,Optional<W>>> |
leftOuterJoin(JavaPairDStream<K,W> other) |
static <W> JavaPairDStream<K,scala.Tuple2<V,Optional<W>>> |
leftOuterJoin(JavaPairDStream<K,W> other,
int numPartitions) |
static <W> JavaPairDStream<K,scala.Tuple2<V,Optional<W>>> |
leftOuterJoin(JavaPairDStream<K,W> other,
Partitioner partitioner) |
static <R> JavaDStream<R> |
map(Function<T,R> f) |
static <U> JavaDStream<U> |
mapPartitions(FlatMapFunction<java.util.Iterator<T>,U> f) |
static <K2,V2> JavaPairDStream<K2,V2> |
mapPartitionsToPair(PairFlatMapFunction<java.util.Iterator<T>,K2,V2> f) |
static <K2,V2> JavaPairDStream<K2,V2> |
mapToPair(PairFunction<T,K2,V2> f) |
static <U> JavaPairDStream<K,U> |
mapValues(Function<V,U> f) |
static <StateType,MappedType> |
mapWithState(StateSpec<K,V,StateType,MappedType> spec) |
static JavaPairDStream<K,V> |
persist() |
static JavaPairDStream<K,V> |
persist(StorageLevel storageLevel) |
static void |
print() |
static void |
print(int num) |
ReceiverInputDStream<scala.Tuple2<K,V>> |
receiverInputDStream() |
static JavaDStream<T> |
reduce(Function2<T,T,T> f) |
static JavaPairDStream<K,V> |
reduceByKey(Function2<V,V,V> func) |
static JavaPairDStream<K,V> |
reduceByKey(Function2<V,V,V> func,
int numPartitions) |
static JavaPairDStream<K,V> |
reduceByKey(Function2<V,V,V> func,
Partitioner partitioner) |
static JavaPairDStream<K,V> |
reduceByKeyAndWindow(Function2<V,V,V> reduceFunc,
Duration windowDuration) |
static JavaPairDStream<K,V> |
reduceByKeyAndWindow(Function2<V,V,V> reduceFunc,
Duration windowDuration,
Duration slideDuration) |
static JavaPairDStream<K,V> |
reduceByKeyAndWindow(Function2<V,V,V> reduceFunc,
Duration windowDuration,
Duration slideDuration,
int numPartitions) |
static JavaPairDStream<K,V> |
reduceByKeyAndWindow(Function2<V,V,V> reduceFunc,
Duration windowDuration,
Duration slideDuration,
Partitioner partitioner) |
static JavaPairDStream<K,V> |
reduceByKeyAndWindow(Function2<V,V,V> reduceFunc,
Function2<V,V,V> invReduceFunc,
Duration windowDuration,
Duration slideDuration) |
static JavaPairDStream<K,V> |
reduceByKeyAndWindow(Function2<V,V,V> reduceFunc,
Function2<V,V,V> invReduceFunc,
Duration windowDuration,
Duration slideDuration,
int numPartitions,
Function<scala.Tuple2<K,V>,java.lang.Boolean> filterFunc) |
static JavaPairDStream<K,V> |
reduceByKeyAndWindow(Function2<V,V,V> reduceFunc,
Function2<V,V,V> invReduceFunc,
Duration windowDuration,
Duration slideDuration,
Partitioner partitioner,
Function<scala.Tuple2<K,V>,java.lang.Boolean> filterFunc) |
static JavaDStream<T> |
reduceByWindow(Function2<T,T,T> reduceFunc,
Duration windowDuration,
Duration slideDuration) |
static JavaDStream<T> |
reduceByWindow(Function2<T,T,T> reduceFunc,
Function2<T,T,T> invReduceFunc,
Duration windowDuration,
Duration slideDuration) |
static JavaPairDStream<K,V> |
repartition(int numPartitions) |
static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,W>> |
rightOuterJoin(JavaPairDStream<K,W> other) |
static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,W>> |
rightOuterJoin(JavaPairDStream<K,W> other,
int numPartitions) |
static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,W>> |
rightOuterJoin(JavaPairDStream<K,W> other,
Partitioner partitioner) |
static void |
saveAsHadoopFiles(java.lang.String prefix,
java.lang.String suffix) |
static <F extends org.apache.hadoop.mapred.OutputFormat<?,?>> |
saveAsHadoopFiles(java.lang.String prefix,
java.lang.String suffix,
java.lang.Class<?> keyClass,
java.lang.Class<?> valueClass,
java.lang.Class<F> outputFormatClass) |
static <F extends org.apache.hadoop.mapred.OutputFormat<?,?>> |
saveAsHadoopFiles(java.lang.String prefix,
java.lang.String suffix,
java.lang.Class<?> keyClass,
java.lang.Class<?> valueClass,
java.lang.Class<F> outputFormatClass,
org.apache.hadoop.mapred.JobConf conf) |
static void |
saveAsNewAPIHadoopFiles(java.lang.String prefix,
java.lang.String suffix) |
static <F extends org.apache.hadoop.mapreduce.OutputFormat<?,?>> |
saveAsNewAPIHadoopFiles(java.lang.String prefix,
java.lang.String suffix,
java.lang.Class<?> keyClass,
java.lang.Class<?> valueClass,
java.lang.Class<F> outputFormatClass) |
static <F extends org.apache.hadoop.mapreduce.OutputFormat<?,?>> |
saveAsNewAPIHadoopFiles(java.lang.String prefix,
java.lang.String suffix,
java.lang.Class<?> keyClass,
java.lang.Class<?> valueClass,
java.lang.Class<F> outputFormatClass,
org.apache.hadoop.conf.Configuration conf) |
static <F extends org.apache.hadoop.mapreduce.OutputFormat<?,?>> |
saveAsNewAPIHadoopFiles$default$6() |
static JavaDStream<java.lang.Long> |
scalaIntToJavaLong(DStream<java.lang.Object> in) |
static java.util.List<R> |
slice(Time fromTime,
Time toTime) |
static JavaDStream<scala.Tuple2<K,V>> |
toJavaDStream() |
static <U> JavaDStream<U> |
transform(Function<R,JavaRDD<U>> transformFunc) |
static <U> JavaDStream<U> |
transform(Function2<R,Time,JavaRDD<U>> transformFunc) |
static <K2,V2> JavaPairDStream<K2,V2> |
transformToPair(Function<R,JavaPairRDD<K2,V2>> transformFunc) |
static <K2,V2> JavaPairDStream<K2,V2> |
transformToPair(Function2<R,Time,JavaPairRDD<K2,V2>> transformFunc) |
static <U,W> JavaDStream<W> |
transformWith(JavaDStream<U> other,
Function3<R,JavaRDD<U>,Time,JavaRDD<W>> transformFunc) |
static <K2,V2,W> JavaDStream<W> |
transformWith(JavaPairDStream<K2,V2> other,
Function3<R,JavaPairRDD<K2,V2>,Time,JavaRDD<W>> transformFunc) |
static <U,K2,V2> JavaPairDStream<K2,V2> |
transformWithToPair(JavaDStream<U> other,
Function3<R,JavaRDD<U>,Time,JavaPairRDD<K2,V2>> transformFunc) |
static <K2,V2,K3,V3> |
transformWithToPair(JavaPairDStream<K2,V2> other,
Function3<R,JavaPairRDD<K2,V2>,Time,JavaPairRDD<K3,V3>> transformFunc) |
static JavaPairDStream<K,V> |
union(JavaPairDStream<K,V> that) |
static <S> JavaPairDStream<K,S> |
updateStateByKey(Function2<java.util.List<V>,Optional<S>,Optional<S>> updateFunc) |
static <S> JavaPairDStream<K,S> |
updateStateByKey(Function2<java.util.List<V>,Optional<S>,Optional<S>> updateFunc,
int numPartitions) |
static <S> JavaPairDStream<K,S> |
updateStateByKey(Function2<java.util.List<V>,Optional<S>,Optional<S>> updateFunc,
Partitioner partitioner) |
static <S> JavaPairDStream<K,S> |
updateStateByKey(Function2<java.util.List<V>,Optional<S>,Optional<S>> updateFunc,
Partitioner partitioner,
JavaPairRDD<K,S> initialRDD) |
scala.reflect.ClassTag<V> |
vClassTag() |
static scala.reflect.ClassTag<V> |
vManifest() |
static JavaPairDStream<K,V> |
window(Duration windowDuration) |
static JavaPairDStream<K,V> |
window(Duration windowDuration,
Duration slideDuration) |
static JavaPairRDD<K,V> |
wrapRDD(RDD<scala.Tuple2<K,V>> rdd) |
fromInputDStream, inputDStream
cache, classTag, cogroup, cogroup, cogroup, combineByKey, combineByKey, compute, dstream, filter, flatMapValues, fromJavaDStream, fromPairDStream, fullOuterJoin, fullOuterJoin, fullOuterJoin, groupByKey, groupByKey, groupByKey, groupByKeyAndWindow, groupByKeyAndWindow, groupByKeyAndWindow, groupByKeyAndWindow, join, join, join, kManifest, leftOuterJoin, leftOuterJoin, leftOuterJoin, mapValues, mapWithState, persist, persist, reduceByKey, reduceByKey, reduceByKey, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, reduceByKeyAndWindow, repartition, rightOuterJoin, rightOuterJoin, rightOuterJoin, saveAsHadoopFiles, saveAsHadoopFiles, saveAsHadoopFiles, saveAsNewAPIHadoopFiles, saveAsNewAPIHadoopFiles, saveAsNewAPIHadoopFiles, scalaToJavaLong, toJavaDStream, union, updateStateByKey, updateStateByKey, updateStateByKey, updateStateByKey, vManifest, window, window, wrapRDD
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
checkpoint, context, count, countByValue, countByValue, countByValueAndWindow, countByValueAndWindow, countByWindow, flatMap, flatMapToPair, foreachRDD, foreachRDD, glom, map, mapPartitions, mapPartitionsToPair, mapToPair, print, print, reduce, reduceByWindow, reduceByWindow, scalaIntToJavaLong, slice, transform, transform, transformToPair, transformToPair, transformWith, transformWith, transformWithToPair, transformWithToPair
public JavaPairReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag)
public static <K,V> JavaPairReceiverInputDStream<K,V> fromReceiverInputDStream(ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream, scala.reflect.ClassTag<K> evidence$1, scala.reflect.ClassTag<V> evidence$2)
ReceiverInputDStream
to a Java-friendly
JavaReceiverInputDStream
.receiverInputDStream
- (undocumented)evidence$1
- (undocumented)evidence$2
- (undocumented)public static JavaDStream<java.lang.Long> scalaIntToJavaLong(DStream<java.lang.Object> in)
public static void print()
public static void print(int num)
public static JavaDStream<java.lang.Long> count()
public static JavaPairDStream<T,java.lang.Long> countByValue()
public static JavaPairDStream<T,java.lang.Long> countByValue(int numPartitions)
public static JavaDStream<java.lang.Long> countByWindow(Duration windowDuration, Duration slideDuration)
public static JavaPairDStream<T,java.lang.Long> countByValueAndWindow(Duration windowDuration, Duration slideDuration)
public static JavaPairDStream<T,java.lang.Long> countByValueAndWindow(Duration windowDuration, Duration slideDuration, int numPartitions)
public static JavaDStream<java.util.List<T>> glom()
public static StreamingContext context()
public static <R> JavaDStream<R> map(Function<T,R> f)
public static <K2,V2> JavaPairDStream<K2,V2> mapToPair(PairFunction<T,K2,V2> f)
public static <U> JavaDStream<U> flatMap(FlatMapFunction<T,U> f)
public static <K2,V2> JavaPairDStream<K2,V2> flatMapToPair(PairFlatMapFunction<T,K2,V2> f)
public static <U> JavaDStream<U> mapPartitions(FlatMapFunction<java.util.Iterator<T>,U> f)
public static <K2,V2> JavaPairDStream<K2,V2> mapPartitionsToPair(PairFlatMapFunction<java.util.Iterator<T>,K2,V2> f)
public static JavaDStream<T> reduce(Function2<T,T,T> f)
public static JavaDStream<T> reduceByWindow(Function2<T,T,T> reduceFunc, Duration windowDuration, Duration slideDuration)
public static JavaDStream<T> reduceByWindow(Function2<T,T,T> reduceFunc, Function2<T,T,T> invReduceFunc, Duration windowDuration, Duration slideDuration)
public static void foreachRDD(VoidFunction<R> foreachFunc)
public static void foreachRDD(VoidFunction2<R,Time> foreachFunc)
public static <U> JavaDStream<U> transform(Function<R,JavaRDD<U>> transformFunc)
public static <U> JavaDStream<U> transform(Function2<R,Time,JavaRDD<U>> transformFunc)
public static <K2,V2> JavaPairDStream<K2,V2> transformToPair(Function<R,JavaPairRDD<K2,V2>> transformFunc)
public static <K2,V2> JavaPairDStream<K2,V2> transformToPair(Function2<R,Time,JavaPairRDD<K2,V2>> transformFunc)
public static <U,W> JavaDStream<W> transformWith(JavaDStream<U> other, Function3<R,JavaRDD<U>,Time,JavaRDD<W>> transformFunc)
public static <U,K2,V2> JavaPairDStream<K2,V2> transformWithToPair(JavaDStream<U> other, Function3<R,JavaRDD<U>,Time,JavaPairRDD<K2,V2>> transformFunc)
public static <K2,V2,W> JavaDStream<W> transformWith(JavaPairDStream<K2,V2> other, Function3<R,JavaPairRDD<K2,V2>,Time,JavaRDD<W>> transformFunc)
public static <K2,V2,K3,V3> JavaPairDStream<K3,V3> transformWithToPair(JavaPairDStream<K2,V2> other, Function3<R,JavaPairRDD<K2,V2>,Time,JavaPairRDD<K3,V3>> transformFunc)
public static DStream<scala.Tuple2<K,V>> dstream()
public static scala.reflect.ClassTag<K> kManifest()
public static scala.reflect.ClassTag<V> vManifest()
public static JavaPairRDD<K,V> wrapRDD(RDD<scala.Tuple2<K,V>> rdd)
public static JavaPairDStream<K,V> filter(Function<scala.Tuple2<K,V>,java.lang.Boolean> f)
public static JavaPairDStream<K,V> cache()
public static JavaPairDStream<K,V> persist()
public static JavaPairDStream<K,V> persist(StorageLevel storageLevel)
public static JavaPairDStream<K,V> repartition(int numPartitions)
public static JavaPairRDD<K,V> compute(Time validTime)
public static JavaPairDStream<K,V> window(Duration windowDuration)
public static JavaPairDStream<K,V> window(Duration windowDuration, Duration slideDuration)
public static JavaPairDStream<K,V> union(JavaPairDStream<K,V> that)
public static JavaPairDStream<K,java.lang.Iterable<V>> groupByKey()
public static JavaPairDStream<K,java.lang.Iterable<V>> groupByKey(int numPartitions)
public static JavaPairDStream<K,java.lang.Iterable<V>> groupByKey(Partitioner partitioner)
public static JavaPairDStream<K,V> reduceByKey(Function2<V,V,V> func)
public static JavaPairDStream<K,V> reduceByKey(Function2<V,V,V> func, int numPartitions)
public static JavaPairDStream<K,V> reduceByKey(Function2<V,V,V> func, Partitioner partitioner)
public static <C> JavaPairDStream<K,C> combineByKey(Function<V,C> createCombiner, Function2<C,V,C> mergeValue, Function2<C,C,C> mergeCombiners, Partitioner partitioner)
public static <C> JavaPairDStream<K,C> combineByKey(Function<V,C> createCombiner, Function2<C,V,C> mergeValue, Function2<C,C,C> mergeCombiners, Partitioner partitioner, boolean mapSideCombine)
public static JavaPairDStream<K,java.lang.Iterable<V>> groupByKeyAndWindow(Duration windowDuration)
public static JavaPairDStream<K,java.lang.Iterable<V>> groupByKeyAndWindow(Duration windowDuration, Duration slideDuration)
public static JavaPairDStream<K,java.lang.Iterable<V>> groupByKeyAndWindow(Duration windowDuration, Duration slideDuration, int numPartitions)
public static JavaPairDStream<K,java.lang.Iterable<V>> groupByKeyAndWindow(Duration windowDuration, Duration slideDuration, Partitioner partitioner)
public static JavaPairDStream<K,V> reduceByKeyAndWindow(Function2<V,V,V> reduceFunc, Duration windowDuration)
public static JavaPairDStream<K,V> reduceByKeyAndWindow(Function2<V,V,V> reduceFunc, Duration windowDuration, Duration slideDuration)
public static JavaPairDStream<K,V> reduceByKeyAndWindow(Function2<V,V,V> reduceFunc, Duration windowDuration, Duration slideDuration, int numPartitions)
public static JavaPairDStream<K,V> reduceByKeyAndWindow(Function2<V,V,V> reduceFunc, Duration windowDuration, Duration slideDuration, Partitioner partitioner)
public static JavaPairDStream<K,V> reduceByKeyAndWindow(Function2<V,V,V> reduceFunc, Function2<V,V,V> invReduceFunc, Duration windowDuration, Duration slideDuration)
public static JavaPairDStream<K,V> reduceByKeyAndWindow(Function2<V,V,V> reduceFunc, Function2<V,V,V> invReduceFunc, Duration windowDuration, Duration slideDuration, int numPartitions, Function<scala.Tuple2<K,V>,java.lang.Boolean> filterFunc)
public static JavaPairDStream<K,V> reduceByKeyAndWindow(Function2<V,V,V> reduceFunc, Function2<V,V,V> invReduceFunc, Duration windowDuration, Duration slideDuration, Partitioner partitioner, Function<scala.Tuple2<K,V>,java.lang.Boolean> filterFunc)
public static <StateType,MappedType> JavaMapWithStateDStream<K,V,StateType,MappedType> mapWithState(StateSpec<K,V,StateType,MappedType> spec)
public static <S> JavaPairDStream<K,S> updateStateByKey(Function2<java.util.List<V>,Optional<S>,Optional<S>> updateFunc)
public static <S> JavaPairDStream<K,S> updateStateByKey(Function2<java.util.List<V>,Optional<S>,Optional<S>> updateFunc, int numPartitions)
public static <S> JavaPairDStream<K,S> updateStateByKey(Function2<java.util.List<V>,Optional<S>,Optional<S>> updateFunc, Partitioner partitioner)
public static <S> JavaPairDStream<K,S> updateStateByKey(Function2<java.util.List<V>,Optional<S>,Optional<S>> updateFunc, Partitioner partitioner, JavaPairRDD<K,S> initialRDD)
public static <U> JavaPairDStream<K,U> mapValues(Function<V,U> f)
public static <U> JavaPairDStream<K,U> flatMapValues(Function<V,java.lang.Iterable<U>> f)
public static <W> JavaPairDStream<K,scala.Tuple2<java.lang.Iterable<V>,java.lang.Iterable<W>>> cogroup(JavaPairDStream<K,W> other)
public static <W> JavaPairDStream<K,scala.Tuple2<java.lang.Iterable<V>,java.lang.Iterable<W>>> cogroup(JavaPairDStream<K,W> other, int numPartitions)
public static <W> JavaPairDStream<K,scala.Tuple2<java.lang.Iterable<V>,java.lang.Iterable<W>>> cogroup(JavaPairDStream<K,W> other, Partitioner partitioner)
public static <W> JavaPairDStream<K,scala.Tuple2<V,W>> join(JavaPairDStream<K,W> other)
public static <W> JavaPairDStream<K,scala.Tuple2<V,W>> join(JavaPairDStream<K,W> other, int numPartitions)
public static <W> JavaPairDStream<K,scala.Tuple2<V,W>> join(JavaPairDStream<K,W> other, Partitioner partitioner)
public static <W> JavaPairDStream<K,scala.Tuple2<V,Optional<W>>> leftOuterJoin(JavaPairDStream<K,W> other)
public static <W> JavaPairDStream<K,scala.Tuple2<V,Optional<W>>> leftOuterJoin(JavaPairDStream<K,W> other, int numPartitions)
public static <W> JavaPairDStream<K,scala.Tuple2<V,Optional<W>>> leftOuterJoin(JavaPairDStream<K,W> other, Partitioner partitioner)
public static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,W>> rightOuterJoin(JavaPairDStream<K,W> other)
public static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,W>> rightOuterJoin(JavaPairDStream<K,W> other, int numPartitions)
public static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,W>> rightOuterJoin(JavaPairDStream<K,W> other, Partitioner partitioner)
public static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,Optional<W>>> fullOuterJoin(JavaPairDStream<K,W> other)
public static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,Optional<W>>> fullOuterJoin(JavaPairDStream<K,W> other, int numPartitions)
public static <W> JavaPairDStream<K,scala.Tuple2<Optional<V>,Optional<W>>> fullOuterJoin(JavaPairDStream<K,W> other, Partitioner partitioner)
public static void saveAsHadoopFiles(java.lang.String prefix, java.lang.String suffix)
public static <F extends org.apache.hadoop.mapred.OutputFormat<?,?>> void saveAsHadoopFiles(java.lang.String prefix, java.lang.String suffix, java.lang.Class<?> keyClass, java.lang.Class<?> valueClass, java.lang.Class<F> outputFormatClass)
public static <F extends org.apache.hadoop.mapred.OutputFormat<?,?>> void saveAsHadoopFiles(java.lang.String prefix, java.lang.String suffix, java.lang.Class<?> keyClass, java.lang.Class<?> valueClass, java.lang.Class<F> outputFormatClass, org.apache.hadoop.mapred.JobConf conf)
public static void saveAsNewAPIHadoopFiles(java.lang.String prefix, java.lang.String suffix)
public static <F extends org.apache.hadoop.mapreduce.OutputFormat<?,?>> void saveAsNewAPIHadoopFiles(java.lang.String prefix, java.lang.String suffix, java.lang.Class<?> keyClass, java.lang.Class<?> valueClass, java.lang.Class<F> outputFormatClass)
public static <F extends org.apache.hadoop.mapreduce.OutputFormat<?,?>> void saveAsNewAPIHadoopFiles(java.lang.String prefix, java.lang.String suffix, java.lang.Class<?> keyClass, java.lang.Class<?> valueClass, java.lang.Class<F> outputFormatClass, org.apache.hadoop.conf.Configuration conf)
public static JavaDStream<scala.Tuple2<K,V>> toJavaDStream()
public static scala.reflect.ClassTag<scala.Tuple2<K,V>> classTag()
public static <F extends org.apache.hadoop.mapreduce.OutputFormat<?,?>> org.apache.hadoop.conf.Configuration saveAsNewAPIHadoopFiles$default$6()
public static InputDStream<scala.Tuple2<K,V>> inputDStream()
public ReceiverInputDStream<scala.Tuple2<K,V>> receiverInputDStream()
public scala.reflect.ClassTag<K> kClassTag()
kClassTag
in class JavaPairInputDStream<K,V>
public scala.reflect.ClassTag<V> vClassTag()
vClassTag
in class JavaPairInputDStream<K,V>