 
 (defn- get-chunk
   "Returns next chunk for the lazy world iteration"
-  [table partition-key chunk-size last-pk]
+  [^Session session table partition-key chunk-size last-pk]
   (if (nil? (first last-pk))
-    (select table
-            (query/limit chunk-size))
-    (select table
-            (query/where (apply query/token partition-key) [> (apply query/token last-pk)])
-            (query/limit chunk-size))))
+    (select session table
+            (q/limit chunk-size))
+    (select session table
+            (q/where (apply q/token partition-key) [> (apply q/token last-pk)])
+            (q/limit chunk-size))))
 
 (defn iterate-world
   "Lazily iterates through the collection, returning chunks of chunk-size."
-  ([table partition-key chunk-size]
-     (iterate-world table (if (sequential? partition-key)
+  ([^Session session table partition-key chunk-size]
+     (iterate-world session table (if (sequential? partition-key)
                             partition-key
                             [partition-key])
                     chunk-size []))
-  ([table partition-key chunk-size c]
+  ([^Session session table partition-key chunk-size c]
      (lazy-cat c
                (let [last-pk    (map #(get (last c) %) partition-key)
                      next-chunk (get-chunk table partition-key chunk-size last-pk)]
-                 (iterate-world table partition-key chunk-size next-chunk)))))
+                 (iterate-world session table partition-key chunk-size next-chunk)))))

                   (with {:replication
                          {:class \"SimpleStrategy\"
                           :replication_factor 1}}))"
  [& query-params]
  (execute- query-params query/create-keyspace-query))

(defn create-index
  "Creates a new (automatic) secondary index for a given (existing)

      (create-index th/session :users :city
                    (index-name :users_city)
                    (if-not-exists))"
  [^Session session & query-params]
  (execute- session query-params q/create-index-query))

(defn drop-index
  "Drop an existing secondary index. The argument of the statement
