final class Ops[S[_]] extends LiftedOps[QueryFile, S]
- Alphabetic
- By Inheritance
- Ops
- LiftedOps
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
type
FreeS[A] = Free[S, A]
- Definition Classes
- LiftedOps
- type M[A] = EitherT[FreeS, FileSystemError, A]
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
descendantFiles(dir: ADir): M[slamdata.Predef.Map[RFile, Node.Type]]
Returns a Map of all files in this directory and all of it's sub-directories along with it's
Node.TypeFails if the directory does not exist. -
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
evaluate(plan: Fix[LogicalPlan]): Process[ExecM, Data]
Returns the stream of data resulting from evaluating the given
LogicalPlan. -
def
execute(plan: Fix[LogicalPlan], out: AFile): ExecM[slamdata.Predef.Unit]
Returns the path to the result of executing the given
LogicalPlan, using the provided path.Returns the path to the result of executing the given
LogicalPlan, using the provided path.If the given file path exists, it will be overwritten with the results from the query.
-
def
explain(plan: Fix[LogicalPlan]): ExecM[ExecutionPlan]
Returns a description of how the the given logical plan will be executed.
-
def
fileExists(file: AFile): FreeS[slamdata.Predef.Boolean]
Returns whether the given file exists.
-
def
fileExistsM(file: AFile): M[slamdata.Predef.Boolean]
Returns whether the given file exists, lifted into the same monad as the rest of the functions here, for convenience.
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def first(plan: Fix[LogicalPlan]): ExecM[slamdata.Predef.Option[Data]]
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
lift[A](ga: QueryFile[A]): FreeS[A]
- Definition Classes
- LiftedOps
- def listContents(dir: ADir): M[slamdata.Predef.Set[Node]]
-
def
ls(dir: ADir): M[slamdata.Predef.Set[Node]]
Returns the names of the immediate children of the given directory, fails if the directory does not exist.
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
results(plan: Fix[LogicalPlan]): ExecM[Process0[Data]]
Returns a stream of data resulting from evaluating the given
LogicalPlan.Returns a stream of data resulting from evaluating the given
LogicalPlan.This consumes the entire result, if you need control over how much data is consumed, see
evaluate. -
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
- val transforms: Transforms[FreeS]
- val unsafe: Unsafe[S]
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )