scheduling/load_and_run.ipynb (75 lines of code) (raw):

{ "cells": [ { "cell_type": "code", "execution_count": null, "metadata": { "collapsed": true }, "outputs": [], "source": [ "repo_dir = \"tmp\"\n", "repo_https_url = \"https://github.com/mozilla/python_mozetl.git\"" ] }, { "cell_type": "code", "execution_count": null, "metadata": { "collapsed": false }, "outputs": [], "source": [ "!git clone $repo_https_url $repo_dir && cd $repo_dir && python setup.py bdist_egg" ] }, { "cell_type": "code", "execution_count": null, "metadata": { "collapsed": false }, "outputs": [], "source": [ "import os\n", "distpath = repo_dir + '/dist'\n", "sc.addPyFile(os.path.join(distpath, os.listdir(distpath)[0]))" ] }, { "cell_type": "code", "execution_count": null, "metadata": { "collapsed": false, "scrolled": true }, "outputs": [], "source": [ "import mozetl\n", "mozetl.etl_job(sc, sqlContext)" ] } ], "metadata": { "anaconda-cloud": {}, "kernelspec": { "display_name": "Python [conda root]", "language": "python", "name": "conda-root-py" }, "language_info": { "codemirror_mode": { "name": "ipython", "version": 2 }, "file_extension": ".py", "mimetype": "text/x-python", "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython2", "version": "2.7.12" } }, "nbformat": 4, "nbformat_minor": 1 }