leonardonsantos

leonardonsantos

leonardonsantos

version: '3'
services:
  spark:
    image: docker.io/bitnami/spark:2.4.5
    environment:
      - SPARK_MODE=master
      - SPARK_RPC_AUTHENTICATION_ENABLED=no
      - SPARK_RPC_ENCRYPTION_ENABLED=no
      - SPARK_LOCAL_STORAGE_ENCRYPTION_ENABLED=no
      - SPARK_SSL_ENABLED=no

leonardonsantos

---
- hosts: localhost
  connection: local
  gather_facts: no

  vars:
    var_name: "william"
    var_port: "80"

  tasks:

leonardonsantos

// returns tagId
function asanaTagByName(tagName, token) {
  var url = "https://app.asana.com/api/1.0/workspaces/2653227806782/typeahead?type=tag&query=" + encodeURIComponent(tagName);
  
  var options = {
    "muteHttpExceptions": true,
    "method": "get",
    "headers": {
      "Authorization": "Bearer " + token
    }

leonardonsantos

import scala.annotation.tailrec
import scala.collection.mutable.{ArrayBuffer, Map}
import scala.util.Try

class HeapedMap[K, V] (implicit ord: Ordering[V]){
  val dict = Map[K,Int]() // Keeps index of key withing vector
  val vector = ArrayBuffer[(K,V)]()

  override def toString(): String = vector.toString
  def toMap(): scala.collection.immutable.Map[K,V] = dict.mapValues(vector(_)._2).toMap

leonardonsantos

var later = require('later');

var timeString = "0 * * * *";

function nextSchedule(cronTimeString, cont){
    var schedule = later.parse.cron(cronTimeString, true);
    later.date.localTime()
    var results = later.schedule(schedule).next(cont);
    return(results);
}

leonardonsantos

#!/usr/bin/nodejs

var levelup        = require('levelup');
var http           = require("http");

var stream = require('stream');
var util = require('util');
var Transform = stream.Transform || require('readable-stream').Transform;

var server = http.createServer(onRequest);