Index

_

_assertFuncArgs() (job_stream.inline.Work method) _assertNoResult() (job_stream.inline.Work method) _cpuThreadTime() (in module job_stream.common) _decode() (in module job_stream.common) _encode() (in module job_stream.common) _forceCheckpoint() (job_stream.common.Frame method) (job_stream.common.Job method) (job_stream.common.Reducer method) (job_stream.inline._ForceCheckpointAndGoJob method) (job_stream.inline._ForceCheckpointJob method) (job_stream.inline._UnwrapperJob method)

_ForceCheckpointAndGoJob (class in job_stream.inline) _ForceCheckpointJob (class in job_stream.inline) _initMultiprocessingPool() (in module job_stream.common) _listCall() (job_stream.inline.Work method) _StackAlreadyPrintedError _UnwrapperJob (class in job_stream.inline) _Work (class in job_stream.common)

A

append() (job_stream.common._Work method)

Args (class in job_stream.inline)

C

clear() (job_stream.common._Work method)

copy() (job_stream.common._Work method) count() (job_stream.common._Work method)

E

emit() (job_stream.common.Frame method) (job_stream.common.Job method) (job_stream.common.Reducer method) (job_stream.inline._ForceCheckpointAndGoJob method) (job_stream.inline._ForceCheckpointJob method) (job_stream.inline._UnwrapperJob method)

extend() (job_stream.common._Work method)

F

finish() (job_stream.inline.Work method) Frame (class in job_stream.common)

frame() (job_stream.inline.Work method) frameEnd() (job_stream.inline.Work method)

G

getCpuCount() (in module job_stream.common)

getHostCpuCount() (in module job_stream.common) getRank() (in module job_stream.common)

H

handleAdd() (job_stream.common.Reducer method) handleDone() (job_stream.common.Frame method) (job_stream.common.Reducer method) handleFirst() (job_stream.common.Frame method) handleInit() (job_stream.common.Reducer method)

handleJoin() (job_stream.common.Reducer method) handleNext() (job_stream.common.Frame method) handleWork() (job_stream.common.Job method) (job_stream.inline._ForceCheckpointAndGoJob method) (job_stream.inline._ForceCheckpointJob method) (job_stream.inline._UnwrapperJob method)

I

index() (job_stream.common._Work method) init() (job_stream.inline.Work method)

insert() (job_stream.common._Work method) invoke() (in module job_stream) (in module job_stream.common)

J

Job (class in job_stream.common) job() (job_stream.inline.Work method) job_stream (module)

job_stream.baked (module) job_stream.common (module) job_stream.inline (module)

M

map() (in module job_stream.common) (in module job_stream.inline)

Multiple (class in job_stream.inline)

O

Object (class in job_stream.common)

P

pop() (job_stream.common._Work method) postSetup() (job_stream.common.Frame method) (job_stream.common.Job method) (job_stream.common.Reducer method) (job_stream.inline._ForceCheckpointAndGoJob method) (job_stream.inline._ForceCheckpointJob method) (job_stream.inline._UnwrapperJob method)

R

recur() (job_stream.common.Frame method) (job_stream.common.Reducer method) reduce() (job_stream.inline.Work method) Reducer (class in job_stream.common)

remove() (job_stream.common._Work method) result() (job_stream.inline.Work method) reverse() (job_stream.common._Work method) run() (in module job_stream.common) (job_stream.inline.Work method)

S

sort() (job_stream.common._Work method)

sweep() (in module job_stream.baked)

W

with_traceback() (job_stream.common._StackAlreadyPrintedError method)

Work (class in job_stream.inline)