org.apache.storm.localizer

Class LocalizedResource

java.lang.Object

org.apache.storm.localizer.LocalizedResource

public class LocalizedResource
extends Object

Represents a resource that is localized on the supervisor. A localized resource has a .current symlink to the current version file which is named filename.{current version}. There is also a filename.version which contains the latest version.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
LocalizedResource(String key, String fileLoc, boolean uncompressed)
LocalizedResource(String key, String fileLoc, boolean uncompressed, String topo)

Method Summary

Modifier and Type	Method and Description
void	addReference(String topo)
String	getCurrentSymlinkPath()
String	getFilePath()
String	getFilePathWithVersion()
String	getKey()
long	getLastAccessTime()
int	getRefCount()
long	getSize()
String	getVersionFilePath()
boolean	isUncompressed()
void	removeReference(String topo)
protected void	setSize(long size)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

LocalizedResource

public LocalizedResource(String key,
                         String fileLoc,
                         boolean uncompressed)

LocalizedResource

public LocalizedResource(String key,
                         String fileLoc,
                         boolean uncompressed,
                         String topo)

Method Detail

isUncompressed

public boolean isUncompressed()

getKey

public String getKey()

getCurrentSymlinkPath

public String getCurrentSymlinkPath()

getVersionFilePath

public String getVersionFilePath()

getFilePathWithVersion

public String getFilePathWithVersion()

getFilePath

public String getFilePath()

addReference

public void addReference(String topo)

removeReference

public void removeReference(String topo)

getLastAccessTime

public long getLastAccessTime()

setSize

protected void setSize(long size)

getSize

public long getSize()

getRefCount

public int getRefCount()