boolean function ( org . apache . spark . storage . BlockManagerId arg0 ) { throw new RuntimeException ( ) ; }
return true if the driver knows about the given block manager . otherwise , return false , indicating that the block manager should re-register . concode_field_sep PlaceHolder placeHolder concode_field_sep scala.concurrent.Future<scala.collection.Seq<java.lang.Object>> removeBroadcast concode_elem_sep boolean updateBlockInfo concode_elem_sep scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveWithLogging concode_elem_sep scala.collection.immutable.Map<org.apache.spark.storage.BlockManagerId,scala.Tuple2<java.lang.Object,java.lang.Object>> memoryStatus concode_elem_sep org.apache.spark.storage.StorageStatus[] storageStatus concode_elem_sep void removeExecutor concode_elem_sep scala.concurrent.Future<scala.collection.Seq<java.lang.Object>> removeShuffle concode_elem_sep void preStart concode_elem_sep scala.collection.Seq<scala.collection.Seq<org.apache.spark.storage.BlockManagerId>> getLocationsMultipleBlockIds concode_elem_sep scala.collection.mutable.HashMap<org.apache.spark.storage.BlockManagerId,org.apache.spark.storage.BlockManagerInfo> blockManagerInfo concode_elem_sep void removeBlockManager concode_elem_sep scala.collection.mutable.HashMap<java.lang.String,org.apache.spark.storage.BlockManagerId> blockManagerIdByExecutor concode_elem_sep scala.Option<scala.Tuple2<java.lang.String,java.lang.Object>> getActorSystemHostPortForExecutor concode_elem_sep void removeBlockFromWorkers concode_elem_sep scala.concurrent.Future<scala.collection.Seq<java.lang.Object>> removeRdd concode_elem_sep scala.collection.immutable.Map<org.apache.spark.storage.BlockManagerId,scala.concurrent.Future<scala.Option<org.apache.spark.storage.BlockStatus>>> blockStatus concode_elem_sep long slaveTimeout concode_elem_sep scala.collection.Seq<org.apache.spark.storage.BlockManagerId> getPeers concode_elem_sep boolean isLocal concode_elem_sep scala.concurrent.duration.FiniteDuration akkaTimeout concode_elem_sep long checkTimeoutInterval concode_elem_sep void expireDeadHosts concode_elem_sep scala.concurrent.Future<scala.collection.Seq<org.apache.spark.storage.BlockId>> getMatchingBlockIds concode_elem_sep akka.actor.Cancellable timeoutCheckingTask concode_elem_sep scala.collection.Seq<org.apache.spark.storage.BlockManagerId> getLocations concode_elem_sep java.util.HashMap<org.apache.spark.storage.BlockId,scala.collection.mutable.HashSet<org.apache.spark.storage.BlockManagerId>> blockLocations concode_elem_sep void register