irajhedayati

// How to convert a JDBC iterator to a Scala iterator

/* A data model to reflect the content of ResultSet */
case class Movie(mId: Int, title: String, rId: Int, ratingDate: String)

import java.sql.{ ResultSet, Statement }

val stmt: Statement = ???
val rs: ResultSet = statement.executeUpdate("SELECT * FROM movie".stripMargin)

irajhedayati

#!/usr/bin/env bash

if [[ -f /etc/lsb-release ]]; then
  RED=$(tput setaf 1)
  GREEN=$(tput setaf 2)
  YELLOW=$(tput setaf 3)
  NO_COLOUR=$(tput sgr0)
else
  RED="\033[91m"
  GREEN="\033[92m"

irajhedayati

# Install SSH on the machine
sudo apt install openssh-server
sudo systemctl enable ssh
sudo systemctl start ssh

# Create a new user
sudo useradd -m -d /home/iraj/ -s /bin/bash -G sudo iraj
sudo passwd iraj
## pick a password

irajhedayati

irajhedayati

/*
Run Spark shell using spark-shell --packages datastax:spark-cassandra-connector:2.4.0-s_2.11 command
Check the versions compatibility on https://github.com/datastax/spark-cassandra-connector#version-compatibility
*/

import com.datastax.spark.connector._
import org.apache.spark.sql._
val spark = SparkSession.builder().
    appName("Spark SQL practice").master("local[*]").
    config("spark.cassandra.connection.host", "localhost").

irajhedayati

package ir.iraj.ericsson;

import ir.iraj.ericsson.exceptions.IllegalBasePayException;
import ir.iraj.ericsson.exceptions.OverWorkException;

public class EricssonCorporation {

    /**
     * Minimum legal base pay
     */