2014-06-24から1日間の記事一覧
broadcast関数続き def broadcast[T: ClassTag](value: T): Broadcast[T] = { val bc = env.broadcastManager.newBroadcast[T](value, isLocal) cleaner.foreach(_.registerBroadcastForCleanup(bc)) bc } 次はcleaner 前回調査した通りcleanerはOption型のC…
broadcast関数続き def broadcast[T: ClassTag](value: T): Broadcast[T] = { val bc = env.broadcastManager.newBroadcast[T](value, isLocal) cleaner.foreach(_.registerBroadcastForCleanup(bc)) bc } 次はcleaner 前回調査した通りcleanerはOption型のC…