run

#!/bin/bash

# Author: Bin Wu <binwu@google.com>

PWD=`pwd`
JAVA=`which java`
#VER=$(<ver)
IPADDR=$(hostname -I | cut -d ' ' -f 1)

__usage() {
    echo "Usage: run {lc|df|clean}"
}

__local() {
    mvn compile exec:java \
        -Dexec.mainClass=bindiego.BindiegoStreaming \
        -Dexec.args="--output=./output/"
}

__dataflow() {
    mvn -Pdataflow-runner compile exec:java \
        -Dexec.mainClass=bindiego.BindiegoStreaming \
        -Dexec.cleanupDaemonThreads=false \
        -Dexec.args="--project=chris-demo-258505 \
        --streaming=true \
        --autoscalingAlgorithm=THROUGHPUT_BASED \
        --maxNumWorkers=20 \
        --workerMachineType=n1-standard-2 \
        --diskSizeGb=64 \
        --numWorkers=3 \
        --tempLocation=gs://chris-demo/tmp/ \
        --gcpTempLocation=gs://chris-demo/tmp/gcp/ \
        --gcsTempLocation=gs://chris-demo/tmp/gcs/ \
        --stagingLocation=gs://chris-demo/staging/ \
        --runner=DataflowRunner \
        --topic=projects/chris-demo-258505/topics/dingoactions \
        --subscription=projects/chris-demo-258505/subscriptions/dingoactions-sub-2 \
        --numShards=1 \
        --windowSize=6s \
        --allowedLateness=8s \
        --earlyFiringPeriod=2s \
        --lateFiringCount=1 \
        --filenamePrefix=raycom. \
        --outputDir=gs://chris-demo/raycom/out/ \
        --errOutputDir=gs://chris-demo/raycom/out/err/ \
        --bqSchema=gs://chris-demo/raycom/schemas/dingoactions.json \
        --bqOutputTable=google.com:chris-demo-258505:raycom.dingoactions \
        --avroSchema=gs://chris-demo/raycom/schemas/dingoactions.avsc \
        --btInstanceId=bigbase \
        --btTableId=streaming \
        --jdbcClass=com.mysql.cj.jdbc.Driver \
        --jdbcConn=jdbc:mysql://10.140.0.3:3306/gcp \
        --jdbcUsername=gcp \
        --jdbcPassword=gcp2020 \
        --defaultWorkerLogLevel=INFO \
        --jobName=raycom-streaming \
        --region=asia-east1"
        # --update \
}

__clean() {
    mvn clean; rm -f output-*
}

__main() {
    if [ $# -eq 0 ]
    then
        __usage
    else
        case $1 in
            lc)
                __local
                ;;
            df)
                __dataflow
                ;;
            clean)
                __clean
                ;;
            *)
                __usage
                ;;
        esac
    fi
}

__main $@

exit 0