       (let [spec (:spec (data-source-spec-by-job-execution-id conn {:job-execution-id job-execution-id}))]
         (with-open [importer (import/dataset-importer (get spec "source") config)]
           (let [columns (import/columns importer)
-                records (import/records importer)]
+                records (import/records importer)
+                stores (apply assoc {} (interleave columns (repeatedly #(atom {}))))
+                rows-count (atom 0)]
             (import/create-dataset-table conn table-name columns)
             (import/add-key-constraints conn table-name columns)
-            (doseq [record (map (comp import/coerce-to-sql (partial l :raw-row)) records)]
-              (l :coerced record)
+            (doseq [record (map (comp import/coerce-to-sql (partial splitable stores columns)) records)]
+              (swap! rows-count inc)
               (jdbc/insert! conn table-name record))
-            (successful-import conn job-execution-id table-name columns spec claims data-source))))
+            (successful-import conn job-execution-id table-name
+                               (map #(assoc % :splitable
+                                            (map (fn [[k v]] [k (assoc v :rows @rows-count)]) @(last %2)))
+                                    columns stores)
+                               spec claims data-source))))
       (catch Throwable e
         (failed-import conn job-execution-id (.getMessage e) table-name)
         (log/error e)

  (update-failed-job-execution conn {:id job-execution-id
                                     :reason [reason]})
  (drop-table conn {:table-name table-name}))


(defn val->geometry-pgobj
  [v]

                                                    :multipleId multiple-id
                                                    :multipleType multiple-type
                                                    :sort nil
                                                    :splitable splitable
                                                    :title (string/trim title)
                                                    :type (name type)})
                                                 columns)
