Org.Apache.REEF.Common.Tasks.TaskConfiguration Class Reference

Inherits Org.Apache.REEF.Tang.Formats.ConfigurationModuleBuilder.

Static Public Attributes
static readonly RequiredParameter< string >	Identifier = new RequiredParameter<string>()
	The identifier of the task. More...
static readonly RequiredImpl< ITask >	Task = new RequiredImpl<ITask>()
	The task to instantiate. More...
static readonly OptionalImpl< IObserver< ISuspendEvent > >	OnSuspend = new OptionalImpl<IObserver<ISuspendEvent>>()
	for task suspension. More...
static readonly OptionalImpl< IDriverMessageHandler >	OnMessage = new OptionalImpl<IDriverMessageHandler>()
	for messages from the driver. More...
static readonly OptionalImpl< IDriverConnectionMessageHandler >	OnDriverConnectionChanged = new OptionalImpl<IDriverConnectionMessageHandler>()
	for heartbeat status changes from the Driver. More...
static readonly OptionalImpl< IObserver< ICloseEvent > >	OnClose = new OptionalImpl<IObserver<ICloseEvent>>()
	for closure requests from the driver. More...
static readonly OptionalImpl< ITaskMessageSource >	OnSendMessage = new OptionalImpl<ITaskMessageSource>()
	Message source invoked upon each evaluator heartbeat. More...
static readonly OptionalImpl< IObserver< ITaskStart > >	OnTaskStart = new OptionalImpl<IObserver<ITaskStart>>()
	to receive TaskStart after the Task.call() method was called. More...
static readonly OptionalImpl< IObserver< ITaskStop > >	OnTaskStop = new OptionalImpl<IObserver<ITaskStop>>()
	to receive TaskStop after the Task.call() method returned. More...
static readonly OptionalParameter< string >	Memento = new OptionalParameter<string>()
	The memento to be passed to Task.call(). More...

Properties
static ConfigurationModule	ConfigurationModule [get]

Additional Inherited Members
Public Member Functions inherited from Org.Apache.REEF.Tang.Formats.ConfigurationModuleBuilder
	ConfigurationModuleBuilder ()
ConfigurationModuleBuilder	Merge (ConfigurationModule d)
ConfigurationModuleBuilder	BindSetEntry< U, T > (GenericType< U > iface, string impl)
ConfigurationModuleBuilder	BindSetEntry< U, V, T > (GenericType< U > iface, GenericType< V > impl)
ConfigurationModuleBuilder	BindSetEntry< U, T > (GenericType< U > iface, IImpl< T > opt)
ConfigurationModuleBuilder	BindSetEntry< U, T > (GenericType< U > iface, IParam< T > opt)
ConfigurationModuleBuilder	BindList< U, T > (GenericType< U > iface, IList< string > impl)
ConfigurationModuleBuilder	BindList< U, T > (GenericType< U > iface, IImpl< IList< T >> opt)
ConfigurationModuleBuilder	BindList< U, T > (GenericType< U > iface, IParam< IList< T >> opt)
ConfigurationModuleBuilder	BindImplementation< U, T > (GenericType< U > iface, GenericType< T > impl)
ConfigurationModuleBuilder	BindImplementation< T > (GenericType< T > iface, string impl)
ConfigurationModuleBuilder	BindImplementation< U, T > (GenericType< T > iface, IImpl< U > opt)
ConfigurationModuleBuilder	BindNamedParameter< U, T > (GenericType< U > name, string value)
ConfigurationModuleBuilder	BindNamedParameter< U, T > (GenericType< U > name, IParam< T > opt)
ConfigurationModuleBuilder	BindNamedParameter< U, V, T > (GenericType< U > iface, GenericType< V > impl)
ConfigurationModuleBuilder	BindNamedParameter< U, T > (GenericType< U > iface, GenericType< T > impl)
ConfigurationModuleBuilder	BindNamedParameter< U, V, T > (GenericType< U > iface, IImpl< V > opt)
ConfigurationModuleBuilder	BindNamedParameter< U, T > (GenericType< U > iface, IImpl< T > opt)
ConfigurationModuleBuilder	BindConstructor< T, U > (GenericType< T > clazz, GenericType< U > constructor)
ConfigurationModuleBuilder	BindConstructor< T, U > (GenericType< T > cons, IImpl< U > v)
ConfigurationModule	Build ()
ConfigurationModuleBuilder	DeepCopy ()
string	ToString (ISet< FieldInfo > s)
Public Attributes inherited from Org.Apache.REEF.Tang.Formats.ConfigurationModuleBuilder
readonly ICsConfigurationBuilder	B = TangFactory.GetTang().NewConfigurationBuilder()
readonly MonotonicHashSet< FieldInfo >	ReqDecl = new MonotonicHashSet<FieldInfo>()
readonly MonotonicHashSet< FieldInfo >	OptDecl = new MonotonicHashSet<FieldInfo>()
readonly MonotonicHashSet< object >	SetOpts = new MonotonicHashSet<object>()
readonly MonotonicHashMap< object, FieldInfo >	Map = new MonotonicHashMap<object, FieldInfo>()
readonly MonotonicHashMap< Type, object >	FreeImpls = new MonotonicHashMap<Type, object>()
readonly MonotonicHashMap< Type, object >	FreeParams = new MonotonicHashMap<Type, object>()

Member Data Documentation

readonly RequiredParameter<string> Org.Apache.REEF.Common.Tasks.TaskConfiguration.Identifier = new RequiredParameter<string>()

static

The identifier of the task.

readonly OptionalParameter<string> Org.Apache.REEF.Common.Tasks.TaskConfiguration.Memento = new OptionalParameter<string>()

static

The memento to be passed to Task.call().

readonly OptionalImpl<IObserver<ICloseEvent> > Org.Apache.REEF.Common.Tasks.TaskConfiguration.OnClose = new OptionalImpl<IObserver<ICloseEvent>>()

static

for closure requests from the driver.

Defaults to task failure if not bound.

readonly OptionalImpl<IDriverConnectionMessageHandler> Org.Apache.REEF.Common.Tasks.TaskConfiguration.OnDriverConnectionChanged = new OptionalImpl<IDriverConnectionMessageHandler>()

static

for heartbeat status changes from the Driver.

Does not do anything if not bound.

readonly OptionalImpl<IDriverMessageHandler> Org.Apache.REEF.Common.Tasks.TaskConfiguration.OnMessage = new OptionalImpl<IDriverMessageHandler>()

static

for messages from the driver.

Defaults to task failure if not bound.

readonly OptionalImpl<ITaskMessageSource> Org.Apache.REEF.Common.Tasks.TaskConfiguration.OnSendMessage = new OptionalImpl<ITaskMessageSource>()

static

Message source invoked upon each evaluator heartbeat.

readonly OptionalImpl<IObserver<ISuspendEvent> > Org.Apache.REEF.Common.Tasks.TaskConfiguration.OnSuspend = new OptionalImpl<IObserver<ISuspendEvent>>()

static

for task suspension.

Defaults to task failure if not bound.

readonly OptionalImpl<IObserver<ITaskStart> > Org.Apache.REEF.Common.Tasks.TaskConfiguration.OnTaskStart = new OptionalImpl<IObserver<ITaskStart>>()

static

to receive TaskStart after the Task.call() method was called.

readonly OptionalImpl<IObserver<ITaskStop> > Org.Apache.REEF.Common.Tasks.TaskConfiguration.OnTaskStop = new OptionalImpl<IObserver<ITaskStop>>()

static

to receive TaskStop after the Task.call() method returned.

readonly RequiredImpl<ITask> Org.Apache.REEF.Common.Tasks.TaskConfiguration.Task = new RequiredImpl<ITask>()

static

The task to instantiate.

Property Documentation

ConfigurationModule Org.Apache.REEF.Common.Tasks.TaskConfiguration.ConfigurationModule

staticget

---

The documentation for this class was generated from the following file:

• lang/cs/Org.Apache.REEF.Common/Tasks/TaskConfiguration.cs