hochgi

@prefix foaf:     <http://xmlns.com/foaf/0.1/> .
@prefix dc:       <http://purl.org/dc/terms/> .
@prefix locn:     <http://www.w3.org/ns/locn#> .
@prefix madsrdf:  <http://www.loc.gov/mads/rdf/v1#> .
@prefix geonames: <http://www.geonames.org/ontology#> .
@prefix geo:      <http://www.w3.org/2003/01/geo/wgs84_pos#> .
@prefix xmpl:     <http://ont.example.org/2017/v1.0#> .
@prefix time:     <http://www.w3.org/2006/time#> .
@prefix xsd:      <http://www.w3.org/2001/XMLSchema#> .
@prefix rdfs:     <http://www.w3.org/2000/01/rdf-schema#> .

hochgi

# idea stuff
*.iml
.idea/
# scala staff

*.class
*.log

branches.properties
logs

hochgi

implicit class FutureOps(companion: Future.type) {
  
  def unorderedReduce[A, B](in: Iterable[A])
                           (fn: A => Future[B], combop: (B,B) => B)
                           (implicit executor: ExecutionContext): Future[B] = {
    val promises = Array.fill(2 * in.size - 1)(Promise.apply[B])
    var i = 0 // used for iteration optimization (not needing to search for uncompleted promise from start every time)
    in.foreach { a =>
      fn(a).onComplete { t =>
        var p = promises(i)

hochgi

import akka.actor.{ActorSystem, Scheduler}
import com.astoncap.util.concurrent.Async._

import scala.concurrent.{ExecutionContext, Future, Promise}
import scala.concurrent.duration.{Duration, FiniteDuration}
import scala.util.Try

trait Scheduling {

  implicit val scheduling: Scheduling = this

hochgi

hochgi

package com.sparkbeyond.engine.util.logging.eventslogger

import java.nio.charset.StandardCharsets

import akka.Done
import ch.qos.logback.core.rolling.{
  FixedWindowRollingPolicy, 
  RollingFileAppender,
  SizeBasedTriggeringPolicy
}

hochgi

hochgi

package scratch.example;

import java.util.List;

public class Tree {

    int value;
    List<Tree> children;

    public Tree(int value, List<Tree> children) {

hochgi

from typing import Optional

class Tree:
    def __init__(self, value: int, children: list):
        self.value = value
        self.children = children # list of Tree

def format_tree(t: Tree) -> str:
    pass

hochgi

import akka.stream.{Attributes, FlowShape, Inlet, Outlet}
import akka.stream.stage.{GraphStage, GraphStageLogic, InHandler, OutHandler}
import com.typesafe.scalalogging.Logger

object StreamEventInspector {
  def default[T](logger: Logger, context: String, printElem: T => String): StreamEventInspector[T] = {
    val ctx = "[" + context + "] "
    new StreamEventInspector[T](
      () => logger.info(ctx + "upstream completed"),
      ex => logger.error(ctx + "upstream failure", ex),