org.apache.spark.storage

Class TachyonBlockManager

Object

org.apache.spark.storage.TachyonBlockManager

All Implemented Interfaces:

Logging

public class TachyonBlockManager
extends Object
implements Logging

Creates and maintains the logical mapping between logical blocks and tachyon fs locations. By default, one block is mapped to one file with a name given by its BlockId.

Constructor Summary

Constructors

Constructor and Description
TachyonBlockManager(BlockManager blockManager, String rootDirs, String master)

Method Summary

Methods

Modifier and Type	Method and Description
tachyon.client.TachyonFS	client()
boolean	fileExists(tachyon.client.TachyonFile file)
tachyon.client.TachyonFile	getFile(BlockId blockId)
tachyon.client.TachyonFile	getFile(String filename)
String	master()
boolean	removeFile(tachyon.client.TachyonFile file)

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

TachyonBlockManager

public TachyonBlockManager(BlockManager blockManager,
                   String rootDirs,
                   String master)

Method Detail

master

public String master()

client

public tachyon.client.TachyonFS client()

removeFile

public boolean removeFile(tachyon.client.TachyonFile file)

fileExists

public boolean fileExists(tachyon.client.TachyonFile file)

getFile

public tachyon.client.TachyonFile getFile(String filename)

getFile

public tachyon.client.TachyonFile getFile(BlockId blockId)