& | Control.Distributed.Dataset |
Aggr | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrBottomK | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrCollect | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrConst | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrCount | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrDistinct | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrFiltered | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrFromFold | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrFromMonoid | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrFromReduce | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrMax | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrMean | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrMin | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrSum | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
aggrTopK | Control.Distributed.Dataset.Aggr, Control.Distributed.Dataset |
argExecutorMode | Control.Distributed.Fork.Backend |
await | Control.Distributed.Fork |
Backend | |
1 (Type/Class) | Control.Distributed.Fork.Backend, Control.Distributed.Fork, Control.Distributed.Dataset |
2 (Data Constructor) | Control.Distributed.Fork.Backend |
BackendM | Control.Distributed.Fork.Backend |
bExecute | Control.Distributed.Fork.Backend |
cap | Control.Distributed.Fork, Control.Distributed.Dataset |
Closure | Control.Distributed.Fork, Control.Distributed.Dataset |
cpure | Control.Distributed.Fork, Control.Distributed.Dataset |
dAggr | Control.Distributed.Dataset |
Dataset | Control.Distributed.Dataset |
dCoalesce | Control.Distributed.Dataset |
dConcatMap | Control.Distributed.Dataset |
DD | Control.Distributed.Dataset |
dDistinct | Control.Distributed.Dataset |
dDistinctBy | Control.Distributed.Dataset |
defaultOptions | Control.Distributed.Fork.Utils |
dExternal | Control.Distributed.Dataset |
dFetch | Control.Distributed.Dataset |
dFilter | Control.Distributed.Dataset |
dGroupedAggr | Control.Distributed.Dataset |
Dict | |
1 (Data Constructor) | Control.Distributed.Fork, Control.Distributed.Dataset |
2 (Type/Class) | Control.Distributed.Fork, Control.Distributed.Dataset |
dMap | Control.Distributed.Dataset |
dPartition | Control.Distributed.Dataset |
dPipe | Control.Distributed.Dataset |
dToList | Control.Distributed.Dataset |
ExecutorFailed | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
ExecutorFailedException | |
1 (Type/Class) | Control.Distributed.Fork |
2 (Data Constructor) | Control.Distributed.Fork |
ExecutorFinalStatus | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
ExecutorFinished | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
ExecutorPending | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
ExecutorPendingStatus | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
ExecutorStarted | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
ExecutorStatus | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
ExecutorSubmitted | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
ExecutorSucceeded | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
ExecutorWaiting | Control.Distributed.Fork.Backend, Control.Distributed.Fork |
fork | Control.Distributed.Fork |
forkConcurrently | Control.Distributed.Fork.Utils |
fromBackendStdout | Control.Distributed.Fork.Backend |
getExecutablePath | Control.Distributed.Fork.Backend |
Handle | Control.Distributed.Fork |
initDistributedFork | Control.Distributed.Fork, Control.Distributed.Dataset |
liftIO | Control.Distributed.Fork.Backend, Control.Distributed.Dataset |
localProcessBackend | Control.Distributed.Fork.Local, Control.Distributed.Dataset.Local |
mkPartition | Control.Distributed.Dataset |
newThrottle | Control.Concurrent.Throttled |
Options | |
1 (Type/Class) | Control.Distributed.Fork.Utils |
2 (Data Constructor) | Control.Distributed.Fork.Utils |
oRetries | Control.Distributed.Fork.Utils |
oShowProgress | Control.Distributed.Fork.Utils |
Partition | Control.Distributed.Dataset |
pollHandle | Control.Distributed.Fork |
Range | Control.Distributed.Dataset.ShuffleStore |
RangeAll | Control.Distributed.Dataset.ShuffleStore |
RangeOnly | Control.Distributed.Dataset.ShuffleStore |
runBackend | Control.Distributed.Fork.Backend |
runDD | Control.Distributed.Dataset |
runDDWith | Control.Distributed.Dataset |
Serializable | Control.Distributed.Fork |
ShuffleStore | |
1 (Type/Class) | Control.Distributed.Dataset.ShuffleStore, Control.Distributed.Dataset |
2 (Data Constructor) | Control.Distributed.Dataset.ShuffleStore |
ssGet | Control.Distributed.Dataset.ShuffleStore |
ssPut | Control.Distributed.Dataset.ShuffleStore |
started | Control.Distributed.Fork.Backend |
startedDesc | Control.Distributed.Fork.Backend |
StaticHashable | Control.Distributed.Dataset |
staticHashable | Control.Distributed.Dataset |
StaticSerialise | Control.Distributed.Dataset |
staticSerialise | Control.Distributed.Dataset |
submitted | Control.Distributed.Fork.Backend |
submittedDesc | Control.Distributed.Fork.Backend |
Throttle | Control.Concurrent.Throttled |
throttled | Control.Concurrent.Throttled |
throttledBackend | Control.Distributed.Fork.Backend |
toBackendStdin | Control.Distributed.Fork.Backend |
waiting | Control.Distributed.Fork.Backend |
waitingDesc | Control.Distributed.Fork.Backend |
withLocalTmpShuffleStore | Control.Distributed.Dataset.Local |