- Install from github.
git clone https://github.com/apache/incubator-spark.git
cd incubator-sparl
./sbt/sbt assembly
## Rubyのオブジェクトについて | |
### オブジェクトの定義 | |
include/ruby/ruby.hにある。 | |
それぞれのクラスの定義を抜粋する。 | |
```ruby | |
struct RBasic { | |
VALUE flags; |
この章ではRDDの概要について説明します。 最初はRDD($2-1)Sparkで利用するプログラムインタフェース($2-2)について説明します。それからメモリの詳細について説明し($2-3)、最後にSparkのモデルの限界($2-4)について議論します。
RDDは読み込み専用のレコードを分割した集まりです。RDDはオペレーションを通して安定したストレージか他のRDDが作成されます。私たちはこのオペレーションについて他のRDDオペレーションと差別化するためにtransformationsとよびます。例えばmap,filter,joinなどがそれにあたります。
RDDは常に実データを持つ必要はありません。その代わりRDDはストレージのデータからたどれるための情報を持つようにします。これはパワフルな特徴で失敗したあと、再構成できないRDDはプログラムから参照できません。
require "rubygem" | |
require "systemu" | |
require "fileutils" | |
record_dir = "/root/records" | |
FileUtils.mkdir_p(record_dir) if !File.exists?(record_dir) | |
def ready | |
result = systemu("netstat -an | grep 8080 | grep -v grep | grep EST | wc -l")[1].chomp | |
while result.to_i > 80 |
まずはVagrantの1.6以上必要なのでインストール。
java.lang.IllegalArgumentException | |
at java.nio.Buffer.position(Buffer.java:236) | |
at sun.nio.ch.IOUtil.write(IOUtil.java:158) | |
at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:524) | |
at org.eclipse.jetty.io.ChannelEndPoint.flush(ChannelEndPoint.java:172) | |
at org.eclipse.jetty.io.WriteFlusher.write(WriteFlusher.java:337) | |
at org.eclipse.jetty.io.AbstractEndPoint.write(AbstractEndPoint.java:128) | |
at org.eclipse.jetty.websocket.common.io.FrameFlusher$Flusher.flush(FrameFlusher.java:152) | |
at org.eclipse.jetty.websocket.common.io.FrameFlusher$Flusher.process(FrameFlusher.java:216) | |
at org.eclipse.jetty.util.IteratingCallback.processIterations(IteratingCallback.java:233) |
Title: STUFF GOES BAD: ERLANG IN ANGER
AUTHOR: Fred Hebert and Heroku
Link: https://s3.amazonaws.com/erlang-in-anger/text.v1.0.1.pdf
License: a Creative Commons Attribution-NonCommercial-ShareAlike 4.0 International License.