Package org.apache.nemo.runtime.executor.data.metadata

Class LocalFileMetadata<K extends java.io.Serializable>

java.lang.Object

org.apache.nemo.runtime.executor.data.metadata.FileMetadata<K>

org.apache.nemo.runtime.executor.data.metadata.LocalFileMetadata<K>

Type Parameters:

K - the key type of its partitions.

@ThreadSafe
public final class LocalFileMetadata<K extends java.io.Serializable>
extends FileMetadata<K>

This class represents a metadata for a local file Block. It resides in local only, and does not synchronize globally.

Constructor Summary

Constructors

Constructor	Description
LocalFileMetadata()	Constructor.

Method Summary

Modifier and Type	Method	Description
void	commitBlock()	Notifies that all writes are finished for the block corresponding to this metadata.
void	deleteMetadata()	Deletes the metadata.

Methods inherited from class org.apache.nemo.runtime.executor.data.metadata.FileMetadata

getPartitionMetadataList, isCommitted, setCommitted, writePartitionMetadata

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalFileMetadata

public LocalFileMetadata()

Constructor.

Method Detail

deleteMetadata

public void deleteMetadata()

Description copied from class: FileMetadata

Deletes the metadata.

Specified by:

deleteMetadata in class FileMetadata<K extends java.io.Serializable>

See Also:

FileMetadata.deleteMetadata()

commitBlock

public void commitBlock()

Notifies that all writes are finished for the block corresponding to this metadata.

Specified by:

commitBlock in class FileMetadata<K extends java.io.Serializable>