Click or drag to resize

BaseJobRunner Class

Base class for job runners that provides interactive prompting and output file checking support.
Inheritance Hierarchy
SystemObject
  Ookii.Jumbo.JetConfigurable
    Ookii.Jumbo.Jet.JobsBaseJobRunner
      Ookii.Jumbo.Jet.Jobs.BuilderJobBuilderJob

Namespace: Ookii.Jumbo.Jet.Jobs
Assembly: Ookii.Jumbo.Jet (in Ookii.Jumbo.Jet.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1
Syntax
Copy
public abstract class BaseJobRunner : Configurable, 
	IJobRunner

The BaseJobRunner type exposes the following members.

Constructors
 NameDescription
Protected methodBaseJobRunnerInitializes a new instance of the BaseJobRunner class
Top
Properties
 NameDescription
Public propertyBlockSize Gets or sets the block size of the job's output files.
Public propertyDfsConfiguration Gets or sets the configuration used to access the Distributed File System.
(Inherited from Configurable)
Protected propertyFileSystemClient Gets the DFS client.
Public propertyIsInteractive Gets or sets a value that indicates whether the job runner should wait for user input before starting the job and before exitting.
Protected propertyJetClient Gets the jet client.
Public propertyJetConfiguration Gets or sets the configuration used to access the Jet servers.
(Inherited from Configurable)
Public propertyJobOrStageProperties Gets or sets the property values that will override predefined values in the job configuration.
Public propertyJobOrStageSettings Gets or sets additional job or stage settings that will be defined in the job configuration.
Public propertyOverwriteOutput Gets or sets a value that indicates whether the output directory should be deleted, if it exists, before the job is executed.
Public propertyReplicationFactor Gets or sets the replication factor of the job's output files.
Public propertyTaskContext Gets or sets the configuration for the task attempt.
(Inherited from Configurable)
Top
Methods
 NameDescription
Protected methodApplyJobPropertiesAndSettings Adds the values of properties marked with the JobSettingAttribute to the JobSettings dictionary, applies properties set by the JobOrStageProperties property, and adds settings defined by the JobOrStageSettings property, and .
Protected methodCheckAndCreateOutputPath If OverwriteOutput is , deletes the output path and then re-creates it; otherwise, checks if the output path exists and creates it if it doesn't exist and fails if it does.
Public methodEqualsDetermines whether the specified object is equal to the current object.
(Inherited from Object)
Protected methodFinalizeAllows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object)
Public methodFinishJob Called after the job finishes.
Public methodGetHashCodeServes as the default hash function.
(Inherited from Object)
Protected methodGetInputFileSystemEntry Gets a JumboFileSystemEntry instance for the specified path, or throws an exception if the input doesn't exist.
Public methodGetTypeGets the Type of the current instance.
(Inherited from Object)
Protected methodMemberwiseCloneCreates a shallow copy of the current Object.
(Inherited from Object)
Public methodNotifyConfigurationChanged Indicates the configuration has been changed. ApplyConfiguration(Object, DfsConfiguration, JetConfiguration, TaskContext) calls this method after setting the configuration.
(Overrides ConfigurableNotifyConfigurationChanged)
Protected methodPromptIfInteractive Prompts the user to start or exit, if IsInteractive is .
Public methodRunJob Starts the job.
Public methodToStringReturns a string that represents the current object.
(Inherited from Object)
Top
See Also