Skip to content

Instantly share code, notes, and snippets.

View igreenfield's full-sized avatar

Izek Greenfield igreenfield

View GitHub Profile
$challenge = Read-Host "Are you sure you want to delete Teams Cache (Y/N)?"
$challenge = $challenge.ToUpper()
if ($challenge -eq "N"){
Stop-Process -Id $PID
}elseif ($challenge -eq "Y"){
Write-Host "Stopping Teams Process" -ForegroundColor Yellow
try{
Get-Process -ProcessName Teams | Stop-Process -Force
Start-Sleep -Seconds 3
Write-Host "Teams Process Sucessfully Stopped" -ForegroundColor Green
@igreenfield
igreenfield / generated.java
Created November 10, 2019 17:36
spark code generated
This file has been truncated, but you can view the full file.
public Object generate(Object[] references) {
return new GeneratedIteratorForCodegenStage3(references);
}
/*wsc_codegenStageId*/
final class GeneratedIteratorForCodegenStage3 extends org.apache.spark.sql.execution.BufferedRowIterator {
private Object[] references;
private scala.collection.Iterator[] inputs;
private scala.collection.Iterator inputadapter_input_0;
private org.apache.spark.sql.execution.joins.UnsafeHashedRelation bhj_relation_0;
This file has been truncated, but you can view the full file.
public Object generate(Object[] references) {
return new GeneratedIteratorForCodegenStage3(references);
}
/*wsc_codegenStageId*/
final class GeneratedIteratorForCodegenStage3 extends org.apache.spark.sql.execution.BufferedRowIterator {
private Object[] references;
private scala.collection.Iterator[] inputs;
private scala.collection.Iterator inputadapter_input_0;
private org.apache.spark.sql.execution.joins.UnsafeHashedRelation bhj_relation_0;
This file has been truncated, but you can view the full file.
public Object generate(Object[] references) {
return new GeneratedIteratorForCodegenStage3(references);
}
/*wsc_codegenStageId*/
final class GeneratedIteratorForCodegenStage3 extends org.apache.spark.sql.execution.BufferedRowIterator {
private Object[] references;
private scala.collection.Iterator[] inputs;
private scala.collection.Iterator inputadapter_input_0;
private org.apache.spark.sql.execution.joins.UnsafeHashedRelation bhj_relation_0;
@igreenfield
igreenfield / spark.scala
Created April 12, 2018 13:09
sample code for question
package com.execution
import java.lang.Thread.UncaughtExceptionHandler
import java.util.concurrent.TimeUnit
import com.typesafe.scalalogging.StrictLogging
import org.apache.spark.sql.SparkSession
object RunExecutionSample extends StrictLogging {
@igreenfield
igreenfield / Capture_HTTP_traffic.sh
Created June 8, 2017 07:44
Capture HTTP traffic: tcpdump
#!/bin/bash
##########################################
# Generate Filter tool:
# https://www.wireshark.org/tools/string-cf.html
#
# GET Filter:
# tcp[((tcp[12:1] & 0xf0) >> 2):4] = 0x47455420
# POST Filter:
# tcp[((tcp[12:1] & 0xf0) >> 2):4] = 0x504f5354 && tcp[((tcp[12:1] & 0xf0) >> 2) + 4:1] = 0x20
@igreenfield
igreenfield / shoval_rabbitmq_configuration.py
Created May 29, 2017 12:43
create shoval configuration for 2 cluster
import httplib
import json
from string import Template
import urllib
import time
put_headers = {"Content-type": "application/json",
"Authorization": "Basic YWRtaW46YWRtaW4="}
get_headers = {"Authorization": "Basic YWRtaW46YWRtaW4="}
@igreenfield
igreenfield / kill_long_running_processes.py
Created April 5, 2017 08:21
Kill linux processes running more then X time
#!/usr/bin/env python
import psutil, time
max_time_from_start = 86400
parent_pid = 1
process_name = 'java'
string_in_cmd_args = 'workspace'
for process in psutil.process_iter():
try:
@igreenfield
igreenfield / rebalance_rabbitmq.py
Last active July 12, 2017 09:30
Script to rebalance master node for rabbitmq cluster
import httplib
import json
from string import Template
import time
request_template = '{"vhost": "/","name": "$name","pattern": "$pattern","apply-to": "all","definition": {"ha-mode": "nodes","ha-params": ["$node_name"],"ha-sync-mode": "automatic", "queue-master-locator": "min-masters"},"priority": 10}'
post_headers = {"Content-type": "application/json",
@igreenfield
igreenfield / PsetUtils.scala
Last active February 17, 2016 15:44
Util to do projection on case classes
object TestApp extends App {
val temp = Temp("a", "b", List(1, 2, 3, 4))
val psetUtils: PsetUtils = new PsetUtils(classOf[Temp])
println("line 1: " + psetUtils.toMap(temp, List("a", "c")))
println("line 2: " + psetUtils.toMap(temp, List("a")))
println("line 3: " + psetUtils.toMap(temp, List("b")))
println("line 4: " + psetUtils.toMap(temp, List("c")))
println("line 5: " + psetUtils.toMap(temp, List("c", "a", "b")))
}