zero-one.geni.streaming — zero.one/geni 0.0.30

->duration clj

(->duration value)

->java-dstream clj

(->java-dstream dstream)

->time clj

(->time value)

await-termination! clj

(await-termination! context)

await-termination-or-timeout! clj

(await-termination-or-timeout! context timeout)

cache clj

(cache dstream)

checkpoint clj multimethod

compute clj

(compute dstream t)

context clj

(context dstream)

count clj

(count dstream)

count-by-value clj

(count-by-value dstream)

(count-by-value dstream num-partitions)

disk-only clj

disk-only-2 clj

dstream clj

filter clj

(filter dstream f)

flat-map clj

(flat-map dstream f)

flat-map-to-pair clj

(flat-map-to-pair dstream f)

flat-map-values clj

(flat-map-values dstream f)

get-state clj

glom clj

(glom dstream)

map clj

(map dstream f)

map-partitions clj

(map-partitions dstream f)

map-partitions-to-pair clj

(map-partitions-to-pair dstream f)

map-to-pair clj

(map-to-pair dstream f)

mapcat-to-pair clj

memory-and-disk clj

memory-and-disk-2 clj

memory-and-disk-ser clj

memory-and-disk-ser-2 clj

memory-only clj

memory-only-2 clj

memory-only-ser clj

memory-only-ser-2 clj

milliseconds clj

(milliseconds t)

minutes clj

(minutes t)

none clj

off-heap clj

persist clj

(persist dstream)

(persist dstream storage-level)

print clj

(print dstream)

(print dstream num)

reduce clj

(reduce dstream f)

reduce-by-key clj

(reduce-by-key dstream f)

(reduce-by-key dstream f partitions-or-partitioner)

remember clj

(remember context duration)

repartition clj

(repartition dstream num-partitions)

save-as-text-files! clj multimethod

seconds clj

(seconds t)

slide-duration clj

(slide-duration dstream)

socket-text-stream clj

(socket-text-stream context hostname port storage)

spark-context clj

(spark-context context)

ssc clj

(ssc context)

start! clj

(start! context)

state clj

(state context)

stop! clj

(stop! context)

streaming-context clj

(streaming-context spark duration)

text-file-stream clj

(text-file-stream context path)

union clj

(union left right)

wrap-rdd clj

(wrap-rdd dstream rdd)