alluxio.master.meta

Class PathProperties

java.lang.Object

alluxio.master.meta.PathProperties

All Implemented Interfaces:

Checkpointed, DelegatingJournaled, Journaled, JournalEntryIterable

@ThreadSafe
public final class PathProperties
extends Object
implements DelegatingJournaled

Source of truth for path level properties. We assume that operations for path level properties are not highly concurrent, based on this assumption, thread safety in this class is guaranteed by a read write lock, also for simplicity, for an operation on a path, we journal the full properties of the path after the operation is done. If the assumption is incorrect, we need to use a more fine-grained concurrency control method and only journal the changes to the path properties.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PathProperties.State Journaled state of path level properties.

Constructor Summary

Constructors

Constructor and Description
PathProperties()

Method Summary

Modifier and Type	Method and Description
void	add(java.util.function.Supplier<JournalContext> ctx, String path, Map<PropertyKey,String> properties) Adds properties for path.
Map<String,Map<String,String>>	get()
Journaled	getDelegate()
String	hash()
void	remove(java.util.function.Supplier<JournalContext> ctx, String path, Set<String> keys) Removes the specified set of keys from the properties for path.
void	removeAll(java.util.function.Supplier<JournalContext> ctx, String path) Removes all properties for path.
PathPropertiesView	snapshot()

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.journal.DelegatingJournaled

applyAndJournal, getCheckpointName, getJournalEntryIterator, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

Constructor Detail

PathProperties

public PathProperties()

Method Detail

snapshot

public PathPropertiesView snapshot()

Returns:

a snapshot of properties and corresponding hash

get

public Map<String,Map<String,String>> get()

Returns:

a copy of path level properties which is a map from path to property key values

add

public void add(java.util.function.Supplier<JournalContext> ctx,
                String path,
                Map<PropertyKey,String> properties)

Adds properties for path. If there are existing properties for path, they are merged with the new properties. If a property key already exists, its old value is overwritten.

Parameters:

ctx - the journal context

path - the path

properties - the new properties

remove

public void remove(java.util.function.Supplier<JournalContext> ctx,
                   String path,
                   Set<String> keys)

Removes the specified set of keys from the properties for path.

Parameters:

ctx - the journal context

path - the path

keys - the keys to remove

removeAll

public void removeAll(java.util.function.Supplier<JournalContext> ctx,
                      String path)

Removes all properties for path.

Parameters:

ctx - the journal context

path - the path

hash

public String hash()

Returns:

the current hash of properties

getDelegate

public Journaled getDelegate()

Specified by:

getDelegate in interface DelegatingJournaled

Returns:

the object to delegate to