CrossClj

datasplash datasplash.core 0.6.1

SourceDocs



RECENT
    VARS
    *coerce-to-clj*
    *context*
    *main-output*
    *pipeline-builder-caller*
    *side-inputs*
    ->combine-fn
    ->duration
    ->options
    accumulation-mode-enum
    apply-transform
    base-combine-schema
    base-schema
    clean-filename
    clj->kv
    cogroup-by
    cogroup-by-schema
    cogroup-by-transform
    cogroup-transform
    combine
    combine-by
    combine-by-transform
    combine-fn
    combine-schema
    compression-type-enum
    context
    count-fn
    create-timestamp
    dconcat
    ddistinct
    dfilter
    dflatten
    dfrequencies
    dgroup-by
    didentity
    djuxt
    dkey
    dmap
    dmapcat
    dofn
    dpartition-by
    dtry
    dval
    filename-policy
    filename-schema
    filter-fn
    fixed-windows
    frequencies-fn
    from-edn
    generate-input
    get-element-from-context
    get-hostname
    get-pipeline-configuration
    get-pipeline-options
    greedy-emit-cogbkresult
    greedy-read-cogbkresult
    group-by-key
    group-by-transform
    interface->class
    job-name-template
    join-by
    join-by-schema
    json-reader-schema
    json-writer-schema
    kv->clj
    kv-coder-schema
    make-group-specs
    make-keyed-pcollection-tuple
    make-kv
    make-kv-coder
    make-nippy-coder
    make-partition-mapping
    make-pipeline
    make-pipeline*
    map-fn
    map-kv
    map-kv-fn
    map-op
    mapcat-fn
    max-fn
    mean-fn
    min-fn
    mk-default-unwindowed-fn
    mk-default-windowed-fn
    named-schema
    output-to-context
    output-value!
    pardo
    pardo-fn
    pardo-schema
    parse-try
    partition-fn
    pcolltuple->map
    pt->>
    pt-cond->>
    ptransform
    read-edn-file
    read-json-file
    read-text-file
    required-ns
    reverse-map
    run-pipeline
    safe-exec
    safe-exec-cfg
    sample
    scoped-ops-schema
    select-enum-option-fn
    session-windows
    sfn
    side-inputs
    side-outputs
    sink-compression-type-enum
    sliding-windows
    sum-fn
    tapply
    text-reader-schema
    text-writer-schema
    to-edn
    to-edn*
    try-deref
    unloaded-ns-from-ex
    unwrap-ex-info
    val->clj
    view
    view-schema
    wait-pipeline-result
    window-schema
    with-keys
    with-opts
    with-opts-docstr
    with-timestamp
    write-edn-file
    write-edn-file-by
    write-file-by
    write-json-file
    write-json-file-transform
    write-text-file
    write-text-file-by
    write-text-file-by-transform