View FaunaDBTesting.scala
import java.net.{ InetSocketAddress, Socket } | |
import java.time.Duration | |
import java.time.temporal.ChronoUnit.SECONDS | |
import java.util.concurrent.{ TimeUnit, TimeoutException } | |
import java.util.function.{ Consumer, Predicate } | |
import com.dimafeng.testcontainers.{ Container, GenericContainer } | |
import com.faunadb.client.FaunaClient | |
import org.junit.runner.Description |
View fauna-graphql-relations.gql
**************************************************************************** | |
**** FaunaDB Relations: GraphQL schemas, mutations and resulting documents * | |
**************************************************************************** | |
**** One to One Relation *************************************************** | |
SCHEMA: | |
type User { name: String! car: Car } | |
type Car { plate: String! owner: User } | |
MUTATION: | |
mutation Create { | |
createUser(data: { |
View git-patch.sh
git format-patch HEAD~X --stdout > patch | |
git apply --stat patch | |
git apply --reject --whitespace=fix patch |
View udfs.scala
import spark.implicits._ | |
import org.apache.spark.sql.functions.udf | |
import org.apache.spark.sql._ | |
import org.apache.spark.sql.functions._ | |
import org.apache.spark.sql.execution.debug._ | |
val u = udf((a: Int) => a) | |
val df = spark.sparkContext.parallelize(Seq(0)).toDF("0") | |
val res = (1 until 20).foldLeft(df) { case (d, i) => |
View RecursionSchemes.scala
package rs | |
import scala.language.higherKinds | |
import matryoshka.data._ | |
import matryoshka.implicits._ | |
import scalaz._, Scalaz._ | |
trait Expr[A] | |
case class NumLit[A](value: Int) extends Expr[A] |
View 01-iptables.config
files: | |
"/etc/init/eb-docker-iptables.conf": | |
mode: "000644" | |
content: | | |
description "Elastic Beanstalk Default Docker Container Iptables" | |
author "Matthew Tovbin <mtovbin@salesforce.com>" | |
start on started docker | |
stop on stopping docker |
View build.gradle
task classpath << { | |
description 'Print project classpath.' | |
println sourceSets.main.runtimeClasspath.asPath | |
} |
View script.sh
cd /proc/<pid> && echo -n "Max open files=65535:65535" > limits |
View FileAsyncIO.scala
import java.io.IOException | |
import java.nio.ByteBuffer | |
import java.nio.channels.{AsynchronousFileChannel, CompletionHandler} | |
import java.nio.file.Paths | |
import java.nio.file.StandardOpenOption._ | |
import scala.concurrent.{ExecutionContext, Future, Promise} | |
import scala.util.Try | |
/** |
View statsd_trap.py
import socket, select | |
s1 = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) | |
s1.bind(('localhost', 8125)) | |
s2 = socket.socket(socket.AF_INET, socket.SOCK_RAW, socket.IPPROTO_UDP) | |
s2.bind(('localhost', 8125)) | |
while True: | |
r, w, x = select.select([s1, s2], [], []) | |
for i in r: | |
print i, i.recvfrom(131072) |
NewerOlder