start new:
tmux
start new with session name:
tmux new -s myname
package main | |
import ( | |
"fmt" | |
"io" | |
"io/ioutil" | |
"net" | |
"os" | |
"strings" |
Driver: | |
-Write the code according to the navigator's specification | |
-Listen intently to the navigators instructions | |
-Ask questions wherever there is a lack of clarity | |
-Offer alternative solutions if you disagree with the navigator | |
-Where there is disagreement, defer to the navigator. If their idea fails, get to failure quickly and move on | |
-Make sure code is clean | |
-Own the computer / keyboard | |
-Ignore larger issues and focus on the task at hand | |
-Trust the navigator - ultimately the navigator has the final say in what is written |
import io.finch._ | |
import io.finch.syntax._ | |
import shapeless._ | |
import scala.language.existentials | |
trait Route { | |
private object base extends Endpoint[HNil] { | |
def apply(input: Input): Endpoint.Result[HNil] = EndpointResult.NotMatched | |
} | |
I hereby claim:
To claim this, I am signing this object:
{-# LANGUAGE DataKinds #-} | |
{-# LANGUAGE DeriveGeneric #-} | |
{-# LANGUAGE FlexibleContexts #-} | |
{-# LANGUAGE LambdaCase #-} | |
{-# LANGUAGE NamedFieldPuns #-} | |
{-# LANGUAGE OverloadedStrings #-} | |
{-# LANGUAGE QuasiQuotes #-} | |
{-# LANGUAGE RecordWildCards #-} | |
{-# LANGUAGE TypeOperators #-} |
sealed trait Term | |
case class Const(name: String) extends Term | |
case class Var(name: String) extends Term | |
case class Atom(relation: String, terms: Term*) | |
sealed trait Clause | |
case class Rule(head: Atom, body: Atom*) extends Clause | |
case class Fact(atom: Atom) extends Clause | |
case class Query(name: String, atoms: Atom*) extends Clause |
Welcome to the kafka workshop @LINE Taiwan!
Today session will help you get started with doing some basic stream processing using Kafka Streams and KSQL, and how you can manage materialzed views using Kafka Connect.
In what follows, we will give you a detail step-by-step guide on building your first stream processing application. The application considers 2 data sources:
package demo; | |
import java.io.Serializable; | |
import java.security.Principal; | |
import java.util.Collection; | |
import java.util.Collections; | |
import java.util.HashMap; | |
import java.util.Map; | |
import java.util.UUID; |
data Tm = Var Int | Ann Tm Tm | Abs Tm | App Tm Tm | Pi Tm Tm | Fix Tm | Uni | |
data Clos = Clos Tm Env | |
data Dm = DVar Int | DAbs Clos | DNeutral Int [Dm] | DPi Dm Clos | DFix Clos | DUni | |
type Env = [Dm] | |
capp :: Clos -> Dm -> Dm | |
capp (Clos b e) t = eval (t : e) b | |
vapp :: Dm -> Dm -> Dm | |
vapp a b = |