Homebrew is a great little package manager for OS X. If you haven't already, installing it is pretty easy:
ruby -e "$(curl -fsSL https://raw.github.com/Homebrew/homebrew/go/install)"| import akka.actor._ | |
| import akka.stream.scaladsl.Flow | |
| import org.apache.spark.streaming.dstream.ReceiverInputDStream | |
| import org.apache.spark.streaming.receiver.ActorHelper | |
| import akka.actor.{ ExtensionKey, Extension, ExtendedActorSystem } | |
| import scala.reflect.ClassTag | |
| object AkkaStreamSparkIntegration { |
| #!/bin/bash | |
| GIT_REPO="https://github.com/richardxin/test" | |
| if [ $# -ne 2 ]; then | |
| echo "=== Missing arguments ===: \nUSAGE: deploy_note.sh <zeppelin_env> <note_name>" | |
| exit 1 | |
| fi | |
| # replace / with - | |
| file_name="${2/\//-}.json" |
| #!/bin/bash | |
| STATUS_URL="http://$1:8890/api/notebook/job/$2" | |
| # curl -X GET http://ec2-34-215-13-164.us-west-2.compute.amazonaws.com:8890/api/notebook | jq '.body[] | select (.id == "2CX4Y3FAS") | .name' | |
| while true | |
| do | |
| STATUS=`curl -X GET $STATUS_URL | jq -cr '.body[] | .status'` | |
| echo $STATUS |
| #!/bin/bash | |
| # example: sh run_note.sh ec2-34-215-13-164.us-west-2.compute.amazonaws.com 2CX4Y3FAS | |
| # Usage: run_note.sh "<zeppelin_host>" "<note_id>" | |
| # http://[zeppelin-server]:[zeppelin-port]/api/notebook/job/[noteId] | |
| if [ $# -ne 2 ]; then | |
| echo "=== Missing arguments ===: \nUSAGE: run_note.sh <zeppelin_host> <note_id>" | |
| exit 1 | |
| fi |
| #!/bin/bash | |
| # Usage: slackpost "<webhook_url>" "<channel>" "<username>" "<message>" | |
| # also (echo $RANDOM; echo $RANDOM) |slackpost "<channel>" "<username>" | |
| # https://gist.github.com/dopiaza/6449505 | |
| # ------------ | |
| webhook_url=$1 | |
| if [[ $webhook_url == "" ]] | |
| then |