morazow

InsertInto Hive using Spark Exasol Connector

exasol/spark-connector#35

Create Sample Exasol Table

DROP SCHEMA IF EXISTS RETAIL CASCADE;
 
CREATE SCHEMA RETAIL;

morazow

package com.morazow.pi

/**
 * This fun example from famous SICP book for
 * approximating PI value.
 *
 * For more info,
 * https://mitpress.mit.edu/sicp/full-text/sicp/book/node72.html
 *
 */

morazow

def ParallelBFS(cx: Int, cy: Int, grids: Map[(Int, Int), Int]): List[Grid] = {
    val tasksupport = new scala.collection.parallel.ForkJoinTaskSupport(
      new scala.concurrent.forkjoin.ForkJoinPool(4))

    var open   = ParTrieMap[(Int, Int), Int]()
    var closed = ParTrieMap[(Int, Int), Int]()

    open.tasksupport = tasksupport
    closed.tasksupport = tasksupport