Jakub Liska l15k4

🎯

Focusing

E95E 3C62 99AA A603

l15k4 / wercker.yml

Created October 9, 2015 11:00

	box: globalwebindex/busybox-sbt

	services:
	- globalwebindex/busybox-es-test
	- globalwebindex/ftp-test

	build:
	steps:
	- script:
	name: sbt

l15k4 / Dockerfile

Created October 9, 2015 17:41

	FROM frolvlad/alpine-oraclejdk8
	MAINTAINER Jakub Liska [email protected]

	ENV SCALA_VERSION 2.11.7
	ENV SCALA_HOME=/opt/scala-$SCALA_VERSION
	ENV PATH=$PATH:$SCALA_HOME/bin

	RUN apk --update add bash curl

	RUN mkdir /opt && curl -jLks http://downloads.typesafe.com/scala/$SCALA_VERSION/scala-$SCALA_VERSION.tgz \| gunzip -c - \| tar -xf - -C /opt

l15k4 / Dockerfile

Last active October 9, 2015 17:44

	FROM gwiq/scala
	MAINTAINER Jakub Liska [email protected]

	ENV SBT_VERSION 0.13.9
	ENV PATH=$PATH:/opt/sbt

	RUN apk --update add curl bash

	RUN mkdir /opt/sbt
	ADD sbt /opt/sbt/

l15k4 / [email protected]

Created October 12, 2015 11:52

l15k4 / BypassingMerge.scala

Last active January 16, 2016 20:10

	import akka.stream.scaladsl.FlexiMerge.{ReadAny, MergeLogic}
	import akka.stream.{Attributes, FanInShape2}
	import akka.stream.scaladsl.FlexiMerge

	class BypassingMerge[A, B] extends FlexiMerge[A, FanInShape2[A, B, A]](new FanInShape2("BMerge"), Attributes.name("BMerge")) {

	def createMergeLogic(p: PortT): MergeLogic[A] = new MergeLogic[A] {
	override def initialState =
	State[Any](ReadAny(p)) { (ctx, input, element) =>
	if (input eq p.in0)

l15k4 / ParallelMerge.scala

Created January 16, 2016 15:11

	import akka.stream._
	import akka.stream.scaladsl.FlexiMerge
	import akka.stream.scaladsl.FlexiMerge.{Read, ReadAll, MergeLogic}

	import scala.collection.{immutable, mutable}


	class ParallelMergeLogic[A](remainingInlets: mutable.Set[Inlet[A]]) extends MergeLogic[immutable.Seq[A]] {

	override def initialState = State(ReadAll(remainingInlets.toIndexedSeq)) {

l15k4 / BypassMergeTestSuite.scala

Created January 16, 2016 18:30

	import akka.stream.SourceShape
	import akka.stream.scaladsl.{GraphDSL, Sink, Source}
	import akka.stream.testkit.TestSubscriber

	class BypassMergeTestSuite extends AkkaSuite {
	import scala.language.implicitConversions

	def assertBypassWorks[O, B](output: List[O], bypassed: List[B])(launch: TestSubscriber.ManualProbe[O] => Unit) = {
	val source = Source.fromGraph(
	GraphDSL.create() { implicit b =>

l15k4 / NeverThreadSafe.scala

Created January 19, 2016 16:25

	def generateTimeField(format: SimpleDateFormat)(i: Int) = do-stuff-with-thread-unsafe-format
	val curriedF = generateTimeField(new SimpleDateFormat("foo"))_
	List(1,2,3,4).par.map(curriedF)

l15k4 / gist:6d22adc2da75ecd0b4b7

Created January 20, 2016 21:21

	2016-01-20 21:20:08,018 DEBG 'druid-indexing-service' stderr output:
	com.google.inject.CreationException: Guice creation errors:

	1) No implementation for java.util.concurrent.ScheduledExecutorService was bound.
	while locating java.util.concurrent.ScheduledExecutorService
	for parameter 9 at io.druid.indexing.overlord.RemoteTaskRunnerFactory.<init>(RemoteTaskRunnerFactory.java:72)
	at io.druid.cli.CliOverlord$1.configureRunners(CliOverlord.java:201)

	2) No implementation for java.util.concurrent.ScheduledExecutorService was bound.
	while locating java.util.concurrent.ScheduledExecutorService

l15k4 / foo.json

Last active January 21, 2016 18:40