Index

A | B | C | D | E | F | G | H | I | J | K | L | M | N | O | P | R | S | T | U | V | W | Z

A

add() (spartan.rpc.zeromq.ZMQPoller method)

add_bool_flag() (in module spartan.config)

add_dim() (spartan.dense.extent.TileExtent method)

add_flag() (in module spartan.config)

add_optimization() (in module spartan.expr.optimize)

addr (spartan.rpc.common.Server attribute)

(spartan.rpc.zeromq.StubSocket attribute)

addr() (spartan.rpc.common.Client method)

all_eq() (spartan.util.Assert static method)

apply_pass() (in module spartan.expr.optimize)

arange() (in module spartan.expr.builtins)

argmax() (in module spartan.expr.builtins)

(spartan.expr.base.Expr method)

argmin() (in module spartan.expr.builtins)

(spartan.expr.base.Expr method)

as_list() (in module spartan.util)

Assert (class in spartan.util)

assign_mode (spartan.config.Flags attribute)

AssignMode (class in spartan.config)

astype() (in module spartan.expr.builtins)

(spartan.expr.base.Expr method)

B

best_locality() (in module spartan.dense.distarray)

bind() (spartan.rpc.common.SocketBase method)

(spartan.rpc.zeromq.ServerSocket method)

bool_index_mapper() (in module spartan.expr.index)

Broadcast (class in spartan.dense.distarray)

broadcast() (in module spartan.dense.distarray)
broadcast_mapper() (in module spartan.dense.distarray)
BY_CORE (spartan.config.AssignMode attribute)
BY_NODE (spartan.config.AssignMode attribute)

C

capture_exception() (in module spartan.rpc.common)

Client (class in spartan.rpc.common)

client_socket() (in module spartan.rpc.zeromq)

clone() (spartan.dense.extent.TileExtent method)

(spartan.expr.node.Node method)

close() (spartan.rpc.common.Client method)

(spartan.rpc.common.SocketBase method)
(spartan.rpc.zeromq.Socket method)
(spartan.rpc.zeromq.ZMQPoller method)

cluster (spartan.config.Flags attribute)

compute_shape() (spartan.expr.base.Expr method)

(spartan.expr.base.LazyVal method)
(spartan.expr.map.MapExpr method)
(spartan.expr.ndarray.NdArrayExpr method)

compute_slice() (in module spartan.dense.extent)

compute_splits() (in module spartan.dense.distarray)

config_file (spartan.config.Flags attribute)

connect() (in module spartan.rpc)

(spartan.rpc.common.SocketBase method)
(spartan.rpc.zeromq.Socket method)

copy() (spartan.rpc.msg.Message method)

count_calls() (in module spartan.util)

create() (in module spartan.dense.distarray)

(in module spartan.dense.extent)
(spartan.worker.Worker method)

D

dag() (in module spartan.expr.base)

(spartan.expr.base.Expr method)

data (spartan.dense.tile.Tile attribute)

decode() (spartan.rpc.msg.Message static method)

DelTable (class in spartan.rpc.msg)

dependencies() (spartan.expr.base.Expr method)

(spartan.expr.base.LazyVal method)
(spartan.expr.ndarray.NdArrayExpr method)
(spartan.expr.optimize.LVal method)

destroy() (spartan.worker.Worker method)

DistArray (class in spartan.dense.distarray)

divup() (in module spartan.util)
done() (spartan.rpc.common.PendingRequest method)
dot() (in module spartan.expr.builtins)
drop_axis() (in module spartan.dense.extent)
DummyFuture (class in spartan.rpc.common)
dump_stacks() (in module spartan.util)

E

eager() (in module spartan.expr.base)
Empty (class in spartan.rpc.msg)
empty() (in module spartan.dense.distarray)
encode() (spartan.rpc.msg.Message method)
Entry (class in spartan.rpc.msg)
eq() (spartan.util.Assert static method)
eq_members() (spartan.expr.node.Node method)

eval_Index() (in module spartan.expr.index)

eval_Slice() (in module spartan.expr.index)

evaluate() (in module spartan.expr.backend)

(in module spartan.expr.base)
(spartan.expr.base.Expr method)
(spartan.expr.base.LazyCollection method)
(spartan.expr.base.LazyVal method)
(spartan.expr.index.IndexExpr method)
(spartan.expr.loop.LoopExpr method)
(spartan.expr.map.MapExpr method)
(spartan.expr.ndarray.NdArrayExpr method)
(spartan.expr.optimize.LocalOp method)
(spartan.expr.reduce.ReduceExpr method)
(spartan.expr.shuffle.ShuffleExpr method)

Exception (class in spartan.rpc.msg)

Expr (class in spartan.expr.base)

extent_for_blob() (spartan.dense.distarray.DistArray method)

EZTimer (class in spartan.util)

F

fake_netflix_mapper() (in module spartan.examples.netflix)

fetch() (spartan.dense.distarray.Broadcast method)

(spartan.dense.distarray.DistArray method)
(spartan.dense.distarray.Slice method)

FileWatchdog (class in spartan.util)

find_overlapping() (in module spartan.dense.extent)

find_shape() (in module spartan.dense.extent)

findCaller() (in module spartan.util)

Flags (class in spartan.config)

flatten() (in module spartan.util)

flush() (spartan.rpc.common.SocketBase method)

(spartan.rpc.zeromq.Socket method)

FnFuture (class in spartan.rpc.common)

forall() (in module spartan.rpc.common)

force() (in module spartan.expr.base)

(spartan.expr.base.Expr method)

foreach() (spartan.dense.distarray.Broadcast method)

(spartan.dense.distarray.DistArray method)
(spartan.dense.distarray.Slice method)

from_data() (in module spartan.dense.tile)

from_intersection() (in module spartan.dense.tile)

from_shape() (in module spartan.dense.extent)

(in module spartan.dense.tile)

from_slice() (in module spartan.dense.extent)

from_table() (in module spartan.dense.distarray)

Future (class in spartan.rpc.common)

FutureGroup (class in spartan.rpc.common)

G

ge() (spartan.util.Assert static method)

get() (spartan.dense.tile.Tile method)

(spartan.worker.Worker method)

get_members() (in module spartan.expr.node)

get_mro() (in module spartan.expr.node)

get_reverse_mro() (in module spartan.expr.node)

get_worker() (spartan.worker.Worker method)

GetRequest (class in spartan.rpc.msg)

GetResponse (class in spartan.rpc.msg)

glom() (in module spartan.expr.base)

(spartan.dense.distarray.DistArray method)
(spartan.dense.distarray.Slice method)
(spartan.expr.base.Expr method)

Group (class in spartan.rpc.common)

gt() (spartan.util.Assert static method)

H

handle_close() (spartan.rpc.zeromq.Socket method)

handle_read() (spartan.rpc.common.Client method)

(spartan.rpc.common.Server method)
(spartan.rpc.zeromq.ServerSocket method)
(spartan.rpc.zeromq.Socket method)

handle_write() (spartan.rpc.zeromq.Socket method)
host (spartan.rpc.zeromq.Socket attribute)

I

id() (spartan.dense.distarray.DistArray method)

in_poll_loop() (spartan.rpc.zeromq.Socket method)

index_for_reduction() (in module spartan.dense.extent)

IndexExpr (class in spartan.expr.index)

initialize() (spartan.worker.Worker method)

int_index_mapper() (in module spartan.expr.index)

intersection() (in module spartan.dense.extent)

(spartan.dense.extent.TileExtent method)

isinstance() (spartan.util.Assert static method)

items() (spartan.expr.node.Node method)

iterable() (in module spartan.util)

(spartan.util.Assert static method)

IteratorRequest (class in spartan.rpc.msg)

IteratorResponse (class in spartan.rpc.msg)

iteritems() (spartan.expr.node.Node method)

itervalues() (spartan.expr.node.Node method)

J

join_tuple() (in module spartan.util)

K

KernelRequest (class in spartan.rpc.msg)

KernelResponse (class in spartan.rpc.msg)

L

largest_value() (in module spartan.dense.distarray)
lazify() (in module spartan.expr.base)
LazyCollection (class in spartan.expr.base)
LazyDict (class in spartan.expr.base)
LazyList (class in spartan.expr.base)
LazyTuple (class in spartan.expr.base)
LazyVal (class in spartan.expr.base)
le() (spartan.util.Assert static method)
listen() (in module spartan.rpc)

LMap (class in spartan.expr.optimize)
load_netflix_mapper() (in module spartan.examples.netflix)
LocalOp (class in spartan.expr.optimize)
log_level (spartan.config.Flags attribute)
loop() (in module spartan.expr.loop)
LoopExpr (class in spartan.expr.loop)
LReduce (class in spartan.expr.optimize)
lt() (spartan.util.Assert static method)
LVal (class in spartan.expr.optimize)

M

make_primitive() (in module spartan.expr.base)

map() (in module spartan.expr.map)

map_like() (in module spartan.expr.optimize)

map_to_array() (in module spartan.dense.distarray)

map_to_table() (spartan.dense.distarray.Broadcast method)

(spartan.dense.distarray.DistArray method)
(spartan.dense.distarray.Slice method)

MapExpr (class in spartan.expr.map)

MapMapFusion (class in spartan.expr.optimize)

maxpool() (in module spartan.expr.stencil)

mean() (in module spartan.expr.builtins)

(spartan.expr.base.Expr method)

members() (spartan.expr.node.Node class method)

merge_tiles() (in module spartan.dense.tile)

Message (class in spartan.rpc.msg)

modify() (spartan.rpc.zeromq.ZMQPoller method)

N

name (spartan.expr.optimize.MapMapFusion attribute)

(spartan.expr.optimize.NumexprFusionPass attribute)
(spartan.expr.optimize.ReduceMapFusion attribute)

ndarray() (in module spartan.expr.ndarray)

NdArrayExpr (class in spartan.expr.ndarray)

ndim (spartan.dense.extent.TileExtent attribute)

ne() (spartan.util.Assert static method)

new_var() (in module spartan.expr.optimize)

no_duplicates() (spartan.util.Assert static method)

Node (class in spartan.expr.node)

node_init() (spartan.expr.base.Expr method)

(spartan.expr.index.IndexExpr method)

node_initializer() (in module spartan.expr.node)

node_type() (in module spartan.expr.node)

(spartan.expr.node.Node method)

NotShapeable

num_workers (spartan.config.Flags attribute)

NumexprFusionPass (class in spartan.expr.optimize)

O

offset_from() (in module spartan.dense.extent)
offset_slice() (in module spartan.dense.extent)
on_finished() (spartan.rpc.common.Future method)
ones() (in module spartan.expr.builtins)
oprofile (spartan.config.Flags attribute)

optimize() (in module spartan.expr.optimize)

OptimizePass (class in spartan.expr.optimize)

outer() (in module spartan.expr.outer)

(spartan.expr.base.Expr method)

outer_product() (in module spartan.expr.outer)

OuterProductExpr (class in spartan.expr.outer)

P

parse_args() (in module spartan.config)
PendingRequest (class in spartan.rpc.common)
pickle() (in module spartan.rpc.common)
pickle_to() (in module spartan.rpc.common)
PickledData (class in spartan.rpc.common)
Ping (class in spartan.rpc.msg)
poller() (in module spartan.rpc.zeromq)

Pong (class in spartan.rpc.msg)
port (spartan.rpc.zeromq.Socket attribute)
port_base (spartan.config.Flags attribute)
profile_kernels (spartan.config.Flags attribute)
profile_master (spartan.config.Flags attribute)
ProxyMethod (class in spartan.rpc.common)

R

rand() (in module spartan.expr.builtins)

randn() (in module spartan.expr.builtins)

ravel() (in module spartan.expr.builtins)

(spartan.expr.base.Expr method)

ravelled_pos() (in module spartan.dense.extent)

(spartan.dense.extent.TileExtent method)

read() (in module spartan.rpc.msg)

recv() (spartan.rpc.common.SocketBase method)

(spartan.rpc.zeromq.Socket method)
(spartan.rpc.zeromq.StubSocket method)

reduce() (in module spartan.expr.reduce)

ReduceExpr (class in spartan.expr.reduce)

ReduceMapFusion (class in spartan.expr.optimize)

Reduction (class in spartan.rpc.msg)

register_handler() (spartan.rpc.common.SocketBase method)

register_method() (spartan.rpc.common.Server method)

register_object() (spartan.rpc.common.Server method)

RemoteException

remove() (spartan.rpc.zeromq.ZMQPoller method)

reshape() (in module spartan.expr.builtins)

RPCException (class in spartan.rpc.common)

rtype_check() (in module spartan.util)

run() (in module spartan.examples.kmeans)

(spartan.util.FileWatchdog method)

run_kernel() (spartan.worker.Worker method)

S

select() (spartan.dense.distarray.DistArray method)

send() (spartan.rpc.common.SocketBase method)

(spartan.rpc.zeromq.ServerSocket method)
(spartan.rpc.zeromq.Socket method)
(spartan.rpc.zeromq.StubSocket method)

serve() (spartan.rpc.common.Server method)

serve_nonblock() (spartan.rpc.common.Server method)

Server (class in spartan.rpc.common)

server_socket() (in module spartan.rpc.zeromq)

ServerSocket (class in spartan.rpc.zeromq)

set_default_timeout() (in module spartan.rpc.common)

sgd() (in module spartan.examples.netflix)

sgd_netflix_mapper() (in module spartan.examples.netflix)

shape (spartan.dense.extent.TileExtent attribute)

(spartan.expr.base.Expr attribute)

shape_for_reduction() (in module spartan.dense.extent)

shapes_match() (in module spartan.dense.extent)

shuffle() (in module spartan.expr.shuffle)

ShuffleExpr (class in spartan.expr.shuffle)

shutdown() (in module spartan.rpc.zeromq)

(spartan.rpc.common.Server method)
(spartan.worker.Worker method)

size (spartan.dense.extent.TileExtent attribute)

size() (in module spartan.expr.builtins)

Slice (class in spartan.dense.distarray)

slice_mapper() (in module spartan.expr.index)

Socket (class in spartan.rpc.zeromq)

SocketBase (class in spartan.rpc.common)

spartan.__init__ (module)

spartan.cluster (module)

spartan.config (module)

spartan.dense.distarray (module)

spartan.dense.extent (module)

spartan.dense.tile (module)

spartan.examples.kmeans (module)

spartan.examples.netflix (module)

spartan.examples.netflix_core (module)

spartan.expr (module)

spartan.expr.backend (module)

spartan.expr.base (module)

spartan.expr.builtins (module)

spartan.expr.index (module)

spartan.expr.loop (module)

spartan.expr.map (module)

spartan.expr.ndarray (module)

spartan.expr.node (module)

spartan.expr.optimize (module)

spartan.expr.outer (module)

spartan.expr.reduce (module)

spartan.expr.shuffle (module)

spartan.expr.stencil (module)

spartan.rpc (module)

spartan.rpc.common (module)

spartan.rpc.msg (module)

spartan.rpc.zeromq (module)

spartan.sparse (module)

spartan.util (module)

spartan.worker (module)

stack_signal() (in module spartan.util)

start_cluster() (in module spartan.cluster)

stencil() (in module spartan.expr.stencil)

stencil_mapper() (in module spartan.expr.stencil)

stop() (spartan.rpc.zeromq.ZMQPoller method)

strata_overlap() (in module spartan.examples.netflix)

StubSocket (class in spartan.rpc.zeromq)

sum() (in module spartan.expr.builtins)

(spartan.expr.base.Expr method)

synchronized() (in module spartan.util)

T

TableDescriptor (class in spartan.rpc.msg)
take_first() (in module spartan.dense.distarray)
Tile (class in spartan.dense.tile)
tile_mapper() (in module spartan.expr.map)
tile_shape() (spartan.dense.distarray.DistArray method)
TileExtent (class in spartan.dense.extent)
tiles_like() (in module spartan.expr.stencil)
timed_out() (spartan.rpc.common.Future method)

timeit() (in module spartan.util)
timer_ctx() (in module spartan.util)
to_global() (spartan.dense.extent.TileExtent method)
to_slice() (spartan.dense.extent.TileExtent method)
trace_fn() (in module spartan.util)
true() (spartan.util.Assert static method)
typename() (spartan.expr.base.Expr method)

U

unravelled_pos() (in module spartan.dense.extent)

Update (class in spartan.rpc.msg)

update() (spartan.dense.distarray.DistArray method)

(spartan.dense.tile.Tile method)
(spartan.worker.Worker method)

update_slice() (spartan.dense.distarray.DistArray method)
UpdateRequest (class in spartan.rpc.msg)
use_threads (spartan.config.Flags attribute)

V

visit() (spartan.expr.base.Expr method)

(spartan.expr.base.LazyDict method)
(spartan.expr.base.LazyList method)
(spartan.expr.base.LazyTuple method)
(spartan.expr.base.LazyVal method)
(spartan.expr.ndarray.NdArrayExpr method)
(spartan.expr.optimize.OptimizePass method)

visit_MapExpr() (spartan.expr.optimize.MapMapFusion method)

(spartan.expr.optimize.NumexprFusionPass method)

visit_ReduceExpr() (spartan.expr.optimize.ReduceMapFusion method)

W

wait() (spartan.rpc.common.DummyFuture method)

(spartan.rpc.common.FnFuture method)
(spartan.rpc.common.Future method)
(spartan.rpc.common.FutureGroup method)
(spartan.rpc.common.PendingRequest method)

wait_for_all() (in module spartan.rpc.common)

wait_for_shutdown() (spartan.worker.Worker method)

wakeup() (spartan.rpc.zeromq.ZMQPoller method)
Worker (class in spartan.worker)
write() (in module spartan.rpc.msg)

Z

zeros() (in module spartan.expr.builtins)

zmq() (spartan.rpc.zeromq.ServerSocket method)

(spartan.rpc.zeromq.Socket method)

ZMQPoller (class in spartan.rpc.zeromq)