The backend for DistributedDriver
A profile and driver for distributed queries.
Represents a computation that needs to be performed by another driver.
Represents a computation that needs to be performed by another driver. Despite having a child it is a NullaryNode because the sub-computation should be opaque to the query compiler.
A simple database engine that stores data in heap data structures.
A profile and driver for interpreted queries on top of the in-memory database.
The querying (read-only) part that can be shared between MemoryDriver and DistributedDriver.
A query interpreter for the MemoryDriver and for client-side operations that need to be run as part of distributed queries against multiple backends.
A query interpreter for the MemoryDriver and for client-side operations that need to be run as part of distributed queries against multiple backends.
It uses ScalaType, ProductValue/StructValue and plain Scala collections to represent data. Queries are expected to be in the shape after running all the standard query compiler phases (but not the extra relational phases) and assigning ScalaTypes everywhere.
A non-streaming Action that wraps a synchronous MemoryProfile API call.
In-memory interpretation of queries and scheduler for distributed queries (i.e. combining several backends).