CrossClj

yieldbot/flambo flambo.streaming 0.8.2

SourceDocs



RECENT
    VARS
    checkpoint
    count
    count-by-window
    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
    text-file-stream
    transform
    union
    window