CrossClj

0.4.0-alpha3 docs

SourceDocs



RECENT
    VARS
    branch
    filter
    fmap
    fmap-vals
    group-by
    group-by-key
    join-left-with-global-table
    join-left-with-stream
    join-left-with-table
    join-outer-with-stream
    join-with-global-table
    join-with-stream
    join-with-table
    map
    map-keys
    map-vals
    process
    side-effect
    sink
    sink-topic
    through
    transform
    transform-vals

    « Index of all namespaces of this project

    — Adam Helinski

    (branch stream preds?)
    (filter stream pred?)
    (fmap kstream f)
    (fmap-vals kstream f)
    (group-by kstream f opts)
    (group-by-key kstream)(group-by-key kstream opts)
    (join-left-with-global-table stream-left gtable-right f-map f-join)
    (join-left-with-stream stream-left stream-right window-ms f)(join-left-with-stream stream-left stream-right window-ms f opts)
    (join-left-with-table stream-left table-right f)(join-left-with-table stream-left table-right f opts)
    (join-outer-with-stream stream-left stream-right window-ms f)(join-outer-with-stream stream-left stream-right window-ms f opts)
    (join-with-global-table stream-left gtable-right f-map f-join)
    (join-with-stream stream-left stream-right window-ms f)(join-with-stream stream-left stream-right window-ms f opts)
    (join-with-table stream-left table-right f)(join-with-table stream-left table-right f opts)
    (map stream f)
    (map-keys stream f)
    (map-vals kstream f)
    (process stream store-names processor)
    (side-effect stream f)
    (sink kstream f)
    (sink-topic kstream topic)(sink-topic kstream topic opts)
    (through stream topic)(through stream topic opts)
    (transform stream store-names transformer)
    (transform-vals stream store-names transformer-vals)