Yoshida grimrose

Scalaz-Streamの基本的なクラスや概念まとめ

ここに記載している情報は間違えている可能性があります。ご注意ください。

Embulkアウトプットプラグイン覚書

やっているのは NodeScheduler のcomputeAssignments のようだ。
locationAwareScheduling と isRemotelyAccessible() によって処理は分岐する、と考えておいて良い
ここでしばしば紹介される minCandidates パラメータが登場する。コードを読む限り、これ、「Split を処理する Node の候補をいくつ選ぶか」というだけであるっぽい。
少なくとも minCandidates の数だけ Node を選び、その中から現在持っているタスクが少ない Node を選んでいるのである。
だから、 minCandidates は別に並列度とは関係ないわけで、結果的にパフォーマンスに寄与するかどうかは微妙な感じもある。
"max number of workers to run a stage in parallel (default: 10) " という説明は誤りなのではないか、という話。
- http://image.slidesharecdn.com/hcj2014-presto-140708205946-phpapp01/95/presto-hadoop-conference-japan-2014-55-638.jpg?cb=1404871295
この minCandidates が node-scheduler.min-candidates であることも確認済みである。
指摘もあったが誰も反応していない https://groups.google.com/forum/#!msg/presto-users/Ft71bkwElkQ/v85ROXC82hIJ

最近マイクロサービスって流行ってますよね。バズってると言ってもいいくらい。

個人的には、「マイクロサービスって結局何なの？」とか、「SOAと何が違うわけ？」とかいう議論は苦手です。

でも「なんでみんなマイクロサービスで作りたいのか？なんでマイクロサービスで作られるサービスが多いのか？」にはすごく興味があるんです。

僕は今、シリコンバレーにある日系SIerの小さな子会社で駐在員をやっていますが、このエリアに居ると、とにかく最近、

「サービス全体が、独立した小さなサービスの集合で構成されるようになってきている」

	import scala.concurrent.Future

	// def successful[T](result: T): Future[T] を使った場合
	// result を評価する時点でブロックされるので
	// a b c の順に表示される
	println("a")
	val f1 = Future.successful { Thread.sleep(1000); println("b") }
	println("c")

	// def apply[T](body: ⇒ T)(implicit execctx: ExecutionContext): Future[T]

	# 優先順位は変わらないので、優先順位にそってメッソドを再定義する
	# メソッドが入れ替わっているので、式内の演算子も置換で入れ替える。
	#
	# ↑優先順位高
	# \| ビット or
	# & ビット and
	# + 加算
	# * 乗算
	# ↓優先順位低
	#

	#!/usr/bin/env ruby

	BIT_OR = '\\|'
	BIT_AND = '\&'
	ADD = '\+'
	MULTIPLATION = '\*'

	input = ARGV[0]

	[BIT_OR, BIT_AND, ADD, MULTIPLATION].each do \|operator\|