|
@@ -81,35 +81,71 @@ public class InMemoryConfigurationStore extends YarnConfigurationStore {
|
|
|
return configVersion;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * Configuration mutations not logged (i.e. not persisted) but directly
|
|
|
+ * confirmed. As such, a list of persisted configuration mutations does not
|
|
|
+ * exist.
|
|
|
+ * @return null Configuration mutation list not applicable for this store.
|
|
|
+ */
|
|
|
@Override
|
|
|
public List<LogMutation> getConfirmedConfHistory(long fromId) {
|
|
|
// Unimplemented.
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * Configuration mutations not logged (i.e. not persisted) but directly
|
|
|
+ * confirmed. As such, a list of persisted configuration mutations does not
|
|
|
+ * exist.
|
|
|
+ * @return null Configuration mutation list not applicable for this store.
|
|
|
+ */
|
|
|
@Override
|
|
|
protected LinkedList<LogMutation> getLogs() {
|
|
|
// Unimplemented.
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * Configuration mutations applied directly in-memory. As such, there is no
|
|
|
+ * persistent configuration store.
|
|
|
+ * As there is no configuration store for versioning purposes,
|
|
|
+ * a conf store version is not applicable.
|
|
|
+ * @return null Conf store version not applicable for this store.
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
@Override
|
|
|
public Version getConfStoreVersion() throws Exception {
|
|
|
// Does nothing.
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * Configuration mutations not logged (i.e. not persisted). As such, they are
|
|
|
+ * not persisted and not versioned. Hence, no version information to store.
|
|
|
+ * @throws Exception
|
|
|
+ */
|
|
|
@Override
|
|
|
public void storeVersion() throws Exception {
|
|
|
// Does nothing.
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * Configuration mutations not logged (i.e. not persisted). As such, they are
|
|
|
+ * not persisted and not versioned. Hence, a current version is not
|
|
|
+ * applicable.
|
|
|
+ * @return null A current version not applicable for this store.
|
|
|
+ */
|
|
|
@Override
|
|
|
public Version getCurrentVersion() {
|
|
|
// Does nothing.
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * Configuration mutations not logged (i.e. not persisted). As such, they are
|
|
|
+ * not persisted and not versioned. Hence, version is always compatible,
|
|
|
+ * since it is in-memory.
|
|
|
+ */
|
|
|
@Override
|
|
|
public void checkVersion() {
|
|
|
// Does nothing. (Version is always compatible since it's in memory)
|