{ "cells": [ { "cell_type": "code", "execution_count": 5, "metadata": { "collapsed": false }, "outputs": [ { "data": { "text/plain": [ "[Row(movieId='1', tagId='1', relevance='0.025000000000000022'),\n", " Row(movieId='1', tagId='2', relevance='0.025000000000000022'),\n", " Row(movieId='1', tagId='3', relevance='0.057750000000000024'),\n", " Row(movieId='1', tagId='4', relevance='0.09675'),\n", " Row(movieId='1', tagId='5', relevance='0.14675')]" ] }, "execution_count": 5, "metadata": {}, "output_type": "execute_result" } ], "source": [ "scores = spark.read.csv(\"/Users/blairhudson/Downloads/ml-20m/genome-scores.csv\",header=True)\n", "scores.take(5)\n", "sqlContext.registerFunction(\"stringLengthString\", lambda x: len(x))\n", "\n" ] }, { "cell_type": "code", "execution_count": 7, "metadata": { "collapsed": false }, "outputs": [ { "data": { "text/plain": [ "[Row(stringLengthString(test)='4')]" ] }, "execution_count": 7, "metadata": {}, "output_type": "execute_result" } ], "source": [ "sqlContext.registerFunction(\"stringLengthString\", lambda x: len(x))\n", "sqlContext.sql(\"SELECT stringLengthString('test')\").collect()" ] }, { "cell_type": "code", "execution_count": null, "metadata": { "collapsed": true }, "outputs": [], "source": [] }, { "cell_type": "markdown", "metadata": {}, "source": [ "" ] } ], "metadata": { "anaconda-cloud": {}, "kernelspec": { "display_name": "Python [conda root]", "language": "python", "name": "conda-root-py" }, "language_info": { "codemirror_mode": { "name": "ipython", "version": 3 }, "file_extension": ".py", "mimetype": "text/x-python", "name": "python", "nbconvert_exporter": "python", "pygments_lexer": "ipython3", "version": "3.5.2" } }, "nbformat": 4, "nbformat_minor": 1 }