beiske

Keybase proof

I hereby claim:

• I am beiske on github.
• I am beiske (https://keybase.io/beiske) on keybase.
• I have a public key whose fingerprint is 83B2 8FD5 4EBF CF81 0FEE FD61 E364 95E0 28B6 36DF

To claim this, I am signing this object:

beiske

import java.nio.file.Files
import scala.concurrent.duration._
import java.nio.file.Paths
import scala.collection.JavaConverters._
import scala.concurrent.ExecutionContext
import org.elasticsearch.client.transport.TransportClient
import org.elasticsearch.common.settings.ImmutableSettings
import org.elasticsearch.common.transport.InetSocketTransportAddress
import com.sksamuel.elastic4s.ElasticClient
import com.sksamuel.elastic4s.ElasticDsl._

beiske

import java.nio.file.Files
import java.nio.file.Paths

import scala.Array.canBuildFrom
import scala.collection.JavaConverters.iterableAsScalaIterableConverter
import scala.concurrent.ExecutionContext.Implicits.global

import org.elasticsearch.client.transport.TransportClient
import org.elasticsearch.common.settings.ImmutableSettings
import org.elasticsearch.common.transport.InetSocketTransportAddress

beiske

analyzer:
    nameAnalyzer:
        filter:
            - lowercase
        type: custom
        tokenizer: keyword

beiske

analyzer:
    nameAnalyzer:
        filter:
            - lowercase
        type: custom
        tokenizer: keyword

beiske

import os
import json
import base64

from elasticsearch.connection.thrift import *

from elasticsearch import Elasticsearch
from elasticsearch.connection import thrift
from elasticsearch.connection.esthrift import Rest

beiske

Create a standard mvn folder structure by putting each file in a folder like this:

├── pom.xml
└── src
    └── test
        ├── java
        │   └── UnknownHostExceptionTest.java
        └── resources
            └── trace.btm

beiske

import scala.Option.option2Iterable
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.Future
import org.elasticsearch.action.search.SearchResponse
import org.elasticsearch.client.transport.TransportClient
import org.elasticsearch.common.settings.ImmutableSettings
import org.elasticsearch.common.transport.InetSocketTransportAddress
import com.sksamuel.elastic4s.ElasticClient
import com.sksamuel.elastic4s.ElasticDsl._
import scala.concurrent.ExecutionContext

beiske

import scala.collection.immutable.Stream.consWrapper
import scala.concurrent.Await
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.Future
import scala.concurrent.duration.Duration
import scala.util.Failure
import scala.util.Success

import org.elasticsearch.action.search.SearchResponse
import org.elasticsearch.client.transport.TransportClient

beiske

  def prefetch[A](slowSource: Stream[A]): Stream[A] = {
    def fetch(stream: => Stream[A]) = {
      Future {
        stream(1)
      }
    }
    def cons(head: Future[A], tail: => Stream[A]): Stream[A] = {
      val next = fetch(tail)
      Await.result(head, Duration.Inf) #:: cons(next, tail.tail)
    }