CrossClj

0.8.2 docs

SourceDocs



RECENT
    VARS
    checkpoint
    count
    count-by-window
    duration
    flat-map
    foreach-rdd
    group-by-key-and-window
    kafka-direct-stream
    kafka-stream
    local-streaming-context
    map
    map-to-pair
    print
    reduce-by-key
    reduce-by-key-and-window
    reduce-by-window
    repartition
    save-as-text-files
    socket-text-stream
    streaming-context
    text-file-stream
    time
    transform
    union
    window

    « Index of all namespaces of this project

    (count dstream)
    (count-by-window dstream window-length slide-interval)
    (flat-map dstream f)
    (foreach-rdd dstream f)
    (group-by-key-and-window dstream window-length slide-interval)
    (kafka-direct-stream streaming-context key-class value-class key-decoder-class value-decoder-class kafka-params topic-set)
    (kafka-stream streaming-context zk-connect group-id topic-map)
    (local-streaming-context app-name duration)
    (map dstream f)
    (map-to-pair dstream f)
    (reduce-by-key dstream f)
    (reduce-by-key-and-window dstream f window-length slide-interval)
    (reduce-by-window dstream f f-inv window-length slide-interval)
    (repartition dstream num-partitions)
    (save-as-text-files dstream prefix suffix)(save-as-text-files dstream prefix)
    (socket-text-stream context ip port)
    (streaming-context conf batch-duration)
    conf can be a SparkConf or JavaSparkContext
    
    (text-file-stream context file-path)
    (transform dstream f)
    (union dstream other-stream)
    (window dstream window-length slide-interval)