crocker

function (user, context, callback) {
  var stripe = require('stripe')('sk_test....');
  
  user.app_metadata = user.app_metadata || {};
	var customer = {
    email: user.email,
    name: user.name
  };
  
  if ('stripe_customer_id' in user.app_metadata) {

crocker

{
	"aggs": {
    	"histogram": {
    		"date_histogram": {
        		"field": "date",
		        "interval": "month"
    		}
    	}
	}
}

crocker

val today = LocalDate.now

val todayTransactions = spark.read
  .option("header", "true")
  .option("inferSchema", "true")
  .json(s"s3n://bucket-name/${today}/transaction.json")

val yesterdayTransactions = spark.read
  .option("header", "true")
  .option("inferSchema", "true")

crocker

val transactions = spark.read
  .option("header", "true")
  .option("inferSchema", "true")
  .json("s3n://bucket-name/transaction.json")

transactions.groupBy("id", "organization").count.sort($"count".desc).show

crocker

package com.databricks.spark.jira

import scala.io.Source

import org.apache.spark.rdd.RDD

import org.apache.spark.sql._
import org.apache.spark.sql.functions._
import org.apache.spark.sql.sources.{TableScan, BaseRelation, RelationProvider}

crocker

db.getCollection('patient').find().snapshot().forEach(
  function (p) {
    var lower_middle_name;
    if(p.middle_name) lower_middle_name = p.middle_name.toLowerCase(); else lower_middle_name = null;
     
    var lower_mrn;
    if(p.mrn) lower_mrn = p.mrn.toLowerCase(); else lower_mrn = null;
     
    var lower_email_address;
    if(p.email_address) lower_email_address = p.email_address.toLowerCase(); else lower_email_address = null;

crocker

// This will print to the logs for the executors
dataRDD.map(c => println(c)).collect()

crocker

// This will not print to your logs (no matter how many times you run it)
dataRDD.map(c => println(c))

crocker

def getDateRange(year: Int, week: Int): (LocalDate, LocalDate) = {
  val date = new LocalDate().withYear(year).withWeekOfWeekyear(week)
  val startDate = date.withDayOfWeek(1)
  val endDate = date.withDayOfWeek(7)

  (startDate, endDate)
}
  
val dateFormat = "yyyy-MM-dd E"
val year = 2016

crocker

db.subscription.updateMany({}, {$set: {last_processed: null}})