EricLondon

var error = undefined;
var result = "wee!";

var chainableMethod = function () {
  return new Promise(function(resolve, reject) {
    if (error) {
      console.log('got error');
      return reject(error);
    }
    console.log('no error');

EricLondon

require 'sidekiq/api'

namespace :sidekiq do
  desc 'Output Sidekiq Status'
  task status: :environment do
    divider = '=================================================='

    puts "#{divider}\nSTATS"
    stats = Sidekiq::Stats.new
    puts "\tProcesses:\t#{stats.processes_size}"

EricLondon

""
.getClass.getMethods.map(_.getName) // methods
.sorted                             // sort
.filter(_ matches "(?i).*index.*")  // grep /index/i

/////////

implicit def toMethods(obj: AnyRef) = new { 
  def methods = obj.getClass.getMethods.map(_.getName)
}

EricLondon

#!/usr/bin/env ruby

require 'open-uri'
require 'json'
require 'pp'

ZEP_HOST = 'localhost'
ZEP_PORT = 8890
ZEP_ADDR = "http://#{ZEP_HOST}:#{ZEP_PORT}"

EricLondon

FROM busybox
ARG MESSAGE
RUN echo $MESSAGE > message.txt

EricLondon

#!/usr/bin/env ruby

require 'json'
require 'net/http'
require 'open-uri'
require 'pp'
require 'uri'

ZEP_HOST = 'localhost'
ZEP_PORT = 8890

EricLondon

////////////////////////////////////////////////////////////////////////////////////////////////////
// Custom UDF
////////////////////////////////////////////////////////////////////////////////////////////////////

// define method
def isNumeric: (String => Boolean) = {
  case null => false
  case value => value forall Character.isDigit
}
val ISNUMERIC = udf(isNumeric)

EricLondon

let method1 = function() {
  console.log("method1")
  return true
}

let method2 = function() {
  console.log("method2")
  return true
}

EricLondon

Map<String, Long> counted = list.stream()
  .collect(Collectors.groupingBy(Function.identity(), Collectors.counting()));

Map<String, Long> sorted = counted.entrySet().stream()
  .sorted(Collections.reverseOrder(Map.Entry.comparingByValue()))
  .limit(10)
  .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue, (e1, e2) -> e1, LinkedHashMap::new));

EricLondon

# usage

nvm use .
npm install
chmod +x export-spark-driver-logs.sh

./export-spark-driver-logs.sh $ES_IP:$ES_PORT driver-##############-####