com.cloudera.gertrude.space

Class AvroExperimentSpaceDeserializer

java.lang.Object

com.cloudera.gertrude.ExperimentSpaceDeserializer

com.cloudera.gertrude.space.AvroExperimentSpaceDeserializer

public class AvroExperimentSpaceDeserializer
extends ExperimentSpaceDeserializer

Constructor Summary

Constructors

Constructor and Description
AvroExperimentSpaceDeserializer(boolean avroFileInput)

Method Summary

Methods

Modifier and Type	Method and Description
protected com.google.common.base.Optional<ExperimentSpace>	deserialize(ExperimentSpace.Serialized serialized) Attempts to convert the ExperimentSpace.Serialized data to an ExperimentSpace, returning Optional.absent() in the case that the deserialization could not be performed.
protected static SortedSet<Integer>	getBuckets(List<Integer> buckets, List<BucketRange> bucketRanges)
protected Condition<ExperimentState>	getCondition(List<ConditionDefinition> definitions, ConditionOperator operator)
protected <T> List<Modifier<T>>	getModifiers(List<ModifierDefinition> definitions, FlagTypeParser<T> parser)
protected static <T> AssociativeOperator<T>	getOperatorFunction(ModifierOperator operator, FlagTypeParser<T> parser)
protected Map<String,FlagValueOverride<Object>>	getOverrides(List<OverrideDefinition> overrides, Map<String,FlagTypeParser<Object>> parsers, int experimentId)
ExperimentSpace	load(ExperimentDeployment deployment, String versionIdentifier)

Methods inherited from class com.cloudera.gertrude.ExperimentSpaceDeserializer

getConditionFactory, getExperimentFlags, initialize

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroExperimentSpaceDeserializer

public AvroExperimentSpaceDeserializer(boolean avroFileInput)

Method Detail

deserialize

protected com.google.common.base.Optional<ExperimentSpace> deserialize(ExperimentSpace.Serialized serialized)
                                                                throws IOException

Description copied from class: ExperimentSpaceDeserializer

Attempts to convert the ExperimentSpace.Serialized data to an ExperimentSpace, returning Optional.absent() in the case that the deserialization could not be performed.

Specified by:

deserialize in class ExperimentSpaceDeserializer

Parameters:

serialized - the serialized form of an ExperimentSpace

Returns:

a valid ExperimentSpace or an Optional.absent() instance

Throws:

IOException - if there is an issue reading the serialized data

load

public ExperimentSpace load(ExperimentDeployment deployment,
                   String versionIdentifier)

getOverrides

protected Map<String,FlagValueOverride<Object>> getOverrides(List<OverrideDefinition> overrides,
                                                 Map<String,FlagTypeParser<Object>> parsers,
                                                 int experimentId)
                                                      throws ValidationException

Throws:

ValidationException

getBuckets

protected static SortedSet<Integer> getBuckets(List<Integer> buckets,
                            List<BucketRange> bucketRanges)

getModifiers

protected <T> List<Modifier<T>> getModifiers(List<ModifierDefinition> definitions,
                                 FlagTypeParser<T> parser)
                                  throws ValidationException

Throws:

ValidationException

getCondition

protected Condition<ExperimentState> getCondition(List<ConditionDefinition> definitions,
                                      ConditionOperator operator)
                                           throws ValidationException

Throws:

ValidationException

getOperatorFunction

protected static <T> AssociativeOperator<T> getOperatorFunction(ModifierOperator operator,
                                             FlagTypeParser<T> parser)