Dask on Yarn
Project description
[![Build Status](https://travis-ci.org/dask/dask-yarn.svg?branch=master)](https://travis-ci.org/dask/dask-yarn)
[![Coverage Status](https://coveralls.io/repos/github/dask/dask-yarn/badge.svg?branch=master)](https://coveralls.io/github/dask/dask-yarn?branch=master)
## Example
```python
>>> from dask_yarn import YARNCluster
>>> cluster = YARNCluster()
>>> from dask.distributed import Client
>>> client = Client(cluster)
>>> cluster.start(2, cpus=1, memory=500)
>>> future = client.submit(lambda x: x + 1, 10)
>>> future.result()
11
```
[![Coverage Status](https://coveralls.io/repos/github/dask/dask-yarn/badge.svg?branch=master)](https://coveralls.io/github/dask/dask-yarn?branch=master)
## Example
```python
>>> from dask_yarn import YARNCluster
>>> cluster = YARNCluster()
>>> from dask.distributed import Client
>>> client = Client(cluster)
>>> cluster.start(2, cpus=1, memory=500)
>>> future = client.submit(lambda x: x + 1, 10)
>>> future.result()
11
```
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
dask-yarn-0.1.1.tar.gz
(18.7 kB
view hashes)