okumin

<?php

/**
 * Copyright (c) 2012 okumin, http://okumin.com/
 * 
 * Permission is hereby granted, free of charge, to any person obtaining
 * a copy of this software and associated documentation files (the
 * "Software"), to deal in the Software without restriction, including
 * without limitation the rights to use, copy, modify, merge, publish,
 * distribute, sublicense, and/or sell copies of the Software, and to

okumin

# -*- coding: utf-8 -*-

class UnionFind:
    def __init__(self):
        self.refs = {}

    def find(self, x):
        if x in self.refs:
            ref = self.find(self.refs[x])
            self.refs[x] = ref

okumin

<?php
require_once "twitteroauth/twitteroauth/twitteroauth.php";

$client = new TwitterOauth(CONSUMER_KEY, CONSUMER_SECRET, ACCESS_TOKEN, ACCESS_TOKEN_SECRET);
$next_cursor = -1;
$target = "";
$f = fopen("./hogehoge.txt", "w");

while($next_cursor != 0) {
    for($i = 0 ; $i < 5; $i++) {

okumin

Bulk insert into Redis

script

import java.io.File
import java.io.PrintWriter
import io.gatling.redis.util.RedisHelper

def generateList(): Unit = {

okumin

akka-persistenceのプラグインをつくろう

• 僕はおくみん
• @okumin

参考

• Persistence — Akka Documentation

Akka persistence is 何

okumin

Excercises

スケイラですみません(◞‸◟) もちがってる可能性があります。

Exercise 2.1

def suffixes[A](xs: List[A]): List[List[A]] = xs match {
  case Nil => List(Nil)

okumin

class MofuSpec extends WordSpec with GeneratorDrivenPropertyChecks {
  def measure(seq: Seq[Int], heap: Heap[Int]): Unit = {
    val h = seq.foldLeft(heap) { (h, x) => h.insert(x) }
    val h2 = seq.foldLeft(h) { (h, x) => h.deleteMin() }
    assert(h2.isEmpty)
  }

  "mofu" should {
    "fumo" in {
      val initial = 300000

okumin

8 Lazy Rebuilding

• 1章: 導入
• 2〜3章: 関数型データ構造の基本的な部分についての紹介
• 4〜7章: 遅延評価と償却の関係 ← ここまでやった
• 8〜11章: 関数型データ構造を設計するための汎用的なテクニック ← 残りはこの部分

この章でやること

• batch rebuilding

okumin

def findMofu(id: Int): Future[CacheError | IOError | NotFound, Mofu] = ???
def createMofu(mofu: Mofu): Future[CacheError | IOError | DuplicateError, Mofu] = ???

val result = findMofu(5).recoverWith {
  case NotFound =>
    createMofu(Mofu(5)).recoverWith {
      case DuplicateError => UnknownError
    }
}

okumin

Summary

MySQL

/	persistAsync	persist	recover
akka-2.3	1547	7964	450
akka-2.4-rc1	1504	9051	390
akka-2.4-batched	702	8806	410
akka-2.4-seq	615	11711	402