sqlingvo.ksql.core — sqlingvo.ksql 0.1.0

as clj/s

(as alias)

(as expr alias)

ast clj/s

(ast statement)

Compile the statement to an AST.

auto-offset-rest clj/s

(auto-offset-rest db value)

create-sink-connector clj/s

(create-sink-connector db name & body)

create-source-connector clj/s

(create-source-connector db name & body)

create-stream clj/s

(create-stream db stream & body)

create-table clj/s

(create-table db stream & body)

create-type clj/s

(create-type db name type)

db clj/s

(db & [config])

Returns a new db.

delete-topic clj/s

(delete-topic)

(delete-topic delete-topic?)

drop-connector clj/s

(drop-connector db connector)

drop-stream clj/s

(drop-stream db stream & body)

drop-table clj/s

(drop-table db table & body)

drop-type clj/s

(drop-type db name)

emit clj/s

(emit result-materialization)

from clj/s

(from source)

group-by clj/s

(group-by & columns)

having clj/s

(having expr)

if-exists clj/s

(if-exists)

(if-exists if-exists?)

insert clj/s

(insert db table columns & body)

Build a INSERT statement.

join clj/s

(join source condition type)

limit clj/s

(limit limit)

list clj/s

(list db type)

order-by clj/s

(order-by & columns)

partition-by clj/s

(partition-by expr)

pp clj/s

(pp statement)

Compile the statement to an AST.

print clj/s

(print db clause)

select clj/s

(select db expr & body)

show clj/s

(show db type)

sql clj/s

(sql statement)

Compile the statement to SQL string..

terminate clj/s

(terminate db query)

values clj/s

(values values)

where clj/s

(where expr)

window clj/s

(window type & expressions)

with clj/s

(with opts)