blob: b290e0ac99c7ebd2b4a085195e0f9026c36bd7ee (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
module Error = struct
open Concepts.Condition
let unknown_relation name =
condition "unknown-relation" "A plan named a relation that does not exist under this snapshot"
("name" |=| Concepts.Value.String name)
let cancelled () =
condition "evaluation-cancelled" "An evaluation was stopped before it produced its result" empty
end
type plan = Base of Protocols.Handle.t
| Project of plan * string BatFingerTree.t
module Program = Protocols.Program.Make (struct
type t = plan
end)
let execute =
let open Utilities.Result in
function
| Base relation_handle ->
Fun.protect
~finally:(fun () -> Protocols.Handle.release relation_handle)
(fun () ->
let* enumerable = Protocols.Enumerable.require relation_handle in
Protocols.Enumerable.enumerate enumerable)
| Project (_plan, _attributes) -> failwith "TODO"
class evaluator = object (self)
inherit Kernel.Lifecycle.null
inherit Kernel.Identity.of_id
method invoke = execute
method protocols : Protocols.Handle.protocol list = [Program.make self]
end
let make () = new evaluator |> Protocols.Handle.make
|
