Package org.apache.flink.api.common.cache

Class DistributedCache.DistributedCacheEntry

java.lang.Object

org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry

All Implemented Interfaces:

Serializable

Enclosing class:

DistributedCache

public static class DistributedCache.DistributedCacheEntry
extends Object
implements Serializable

Meta info about an entry in DistributedCache.

Entries have different semantics for local directories depending on where we are in the job-submission process. After registration through the API filePath denotes the original directory. After the upload to the cluster (which includes zipping the directory), filePath denotes the (server-side) copy of the zip.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
byte[]	blobKey
String	filePath
Boolean	isExecutable
boolean	isZipped

Constructor Summary

Constructors

Constructor	Description
DistributedCacheEntry(String filePath, boolean isExecutable, boolean isZipped)	Client-side constructor used during job-submission for zipped directory.
DistributedCacheEntry(String filePath, Boolean isExecutable)	Client-side constructor used by the API for initial registration.
DistributedCacheEntry(String filePath, Boolean isExecutable, byte[] blobKey)	Server-side constructor used during job-submission for files.
DistributedCacheEntry(String filePath, Boolean isExecutable, byte[] blobKey, boolean isZipped)	Server-side constructor used during job-submission for zipped directories.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

filePath

public String filePath

isExecutable

public Boolean isExecutable

isZipped

public boolean isZipped

blobKey

public byte[] blobKey

Constructor Detail

DistributedCacheEntry

public DistributedCacheEntry(String filePath,
                             Boolean isExecutable)

Client-side constructor used by the API for initial registration.

DistributedCacheEntry

public DistributedCacheEntry(String filePath,
                             boolean isExecutable,
                             boolean isZipped)

Client-side constructor used during job-submission for zipped directory.

DistributedCacheEntry

public DistributedCacheEntry(String filePath,
                             Boolean isExecutable,
                             byte[] blobKey,
                             boolean isZipped)

Server-side constructor used during job-submission for zipped directories.

DistributedCacheEntry

public DistributedCacheEntry(String filePath,
                             Boolean isExecutable,
                             byte[] blobKey)

Server-side constructor used during job-submission for files.

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object