Ookii.Jumbo.Jet Namespace

Indicates that a task, multi record reader or channel reports additional progress.

The value of an additional progress counter.

Attribute for task classes that indicates that the input record reader may reuse the same object instance for every record.

Represents information about a job that has been archived.

Enables the use of GetType(String) to resolve types in assemblies loaded with LoadFrom(String).

Heartbeat response used when the job server wants the task server to clean up data related to a job.

Provides information about a task that has finished executing.

Provides a basic implementation of IConfigurable.

Provides configuration information for the file channel.

A partitioner based on the value returned by GetHashCode(T).

Heartbeat data informing the server of the status

Provides object activation services for Jumbo Jet.

Provides client access to the Jumbo Jet distributed execution engine.

Provides configuration for the Jumbo distributed execution environment.

Base class for data sent by the task servers to the job server.

Base class for heartbeat responses from the job server to the task servers.

Represents information about the current state of the Jet distributed execution engine.

Represents a job.

Provides configuration information about the job server.

Provides status information about the currently running job.

Provides constants for the keys of job and stage settings used by components of Jumbo.

Provides constants for the keys of job and stage settings used by the FileOutputChannel and FileInputChannel.

Provides constants for the keys of settings used by the FileOutputChannel that can appear only in the stage settings.

Provides constants for the keys of settings used by the FileOutputChannel and FileInputChannel that can appear in both the job and stage settings.

Response sent by the job server if the task server must kill the specified task.

Provides methods to merge multiple segments of sorted input into one sorted output.

Record reader that merges the records from multiple sorted input record readers.

Provides configuration for the MergeRecordReaderT.

Contains constants for use by MergeRecordReaderT.

Contains the result of a merge operation.

Represents an output record of a merge operation.

Record reader used for pull tasks with the ProcessAllInputPartitionsAttribute attribute.

Provides constants for use with implementations of IPartitionerT.

Base class for tasks that use the push model and can receive records of multiple partitions.

A record writer for records that have already been partitioned.

Attribute for task classes that indicates that all input partitions should be processed by the same task instance.

Base class for tasks that use the push model.

Heartbeat response used when the job server has a task that the task server should execute.

Represents an error with the distributed file system.

Provides status information about a particular stage.

The identifier of a task attempt.

Provides context for a specific task attempt.

Encapsulates all the data and functionality needed to run a task and its pipelined tasks.

Represents a task identifier.

Provides information about the read and write operations done by a task.

Represents the progress of a task.

Provides configuration information for the task server.

Provides information about task servers.

Provides status information about a task.

Heartbeat data used to inform the job server that the status of a task has changed.

Provides configuration information for the TCP channel.

Interface for classes that need the DFS, Jet, and/or Job configuration.

Interface for tasks, multi record readers and channels that report additional progress.

Provides additional metrics about disk and network activity.

The interface used by clients to communicate with the job server.

Protocol used by the task servers to communicate with the job server.

Protocol used by tasks to communicate with the job server. For Jumbo internal use only.

Interface for task classes.

The protocol used when task servers communicate with each other or when the job server communicates with a task server other than its own.

Interface used by the TaskHost to communicate with its task server.

Indicates how the scheduler should assign tasks to servers.

The current status of a task attempt.

Commands that the job server can send to a task server in response to a hearbeat.

Indicates the current state of a task.