blob: 2e021013bd42e32b83ff0db6de14b79c57d5ecda [file] [log] [blame]
/*
* Copyright 2009-2010 by The Regents of the University of California
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* you may obtain a copy of the License from
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package edu.uci.ics.hyracks.api.application;
import java.io.Serializable;
import edu.uci.ics.hyracks.api.context.ICCContext;
import edu.uci.ics.hyracks.api.job.IJobLifecycleListener;
import edu.uci.ics.hyracks.api.job.IJobSpecificationFactory;
import edu.uci.ics.hyracks.api.job.JobSpecification;
/**
* Application Context at the Cluster Controller for an application.
*
* @author vinayakb
*
*/
public interface ICCApplicationContext extends IApplicationContext {
/**
* Sets the state that must be distributed by the infrastructure to all the
* NC application contects. Any state set by calling thsi method in the
* {@link ICCBootstrap#start()} call is made available to all the
* {@link INCApplicationContext} objects at each Node Controller. The state
* is then available to be inspected by the application at the NC during or
* after the {@link INCBootstrap#start()} call.
*
* @param state
* The distributed state
*/
public void setDistributedState(Serializable state);
/**
* A factory class specific to this application that may accept incoming
* {@link JobSpecification} and produce modified {@link JobSpecification}
* that is executed on the cluster. If a {@link IJobSpecificationFactory} is
* not set, the incoming {@link JobSpecification} is executed unmodified.
*
* @param jobSpecFactory
* - The Job Specification Factory.
*/
public void setJobSpecificationFactory(IJobSpecificationFactory jobSpecFactory);
/**
* A listener that listens to Job Lifecycle events at the Cluster
* Controller.
*
* @param jobLifecycleListener
*/
public void addJobLifecycleListener(IJobLifecycleListener jobLifecycleListener);
/**
* Get the Cluster Controller Context.
*
* @return The Cluster Controller Context.
*/
public ICCContext getCCContext();
}