87be975dc77e37cf4942fc0246c63a0576e1b791 - asterixdb

commit	87be975dc77e37cf4942fc0246c63a0576e1b791	[log] [tgz]
author	vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053>	Fri May 20 17:17:04 2011 +0000
committer	vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053>	Fri May 20 17:17:04 2011 +0000
tree	af157cb6eea290adb922dd44598f6e11a447f616
parent	d705daef71bd0d28ad1214ed0913c96271b1e6f7 [diff]

Cleaned up partition management. Made fault recovery more robust.

git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_scheduling@465 123451ca-8445-de46-9d55-352943316053

hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/connectors/SendSideMaterializedBlockingConnectorPolicy.java[Renamed from hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/connectors/SendSideMaterializedConnectorPolicy.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/connectors/SendSideMaterializedReceiveSideMaterializedBlockingConnectorPolicy.java[Renamed from hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/connectors/SendSideMaterializedReceiveSideMaterializedConnectorPolicy.java - diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/ClusterControllerService.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/job/ActivityCluster.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/job/JobRun.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/job/TaskCluster.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/job/manager/events/JobCleanupEvent.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/job/manager/events/RegisterPartitionAvailibilityEvent.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/job/manager/events/RegisterPartitionRequestEvent.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/job/manager/events/RemoveDeadNodesEvent.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/partitions/PartitionMatchMaker.java[Added - diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/partitions/PartitionUtils.java[Added - diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/DefaultActivityClusterStateMachine.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/DefaultJobRunStateMachine.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/IActivityClusterStateMachine.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/IJobRunStateMachine.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/scheduler/RankedRunnableTaskCluster.java[Added - diff]
hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/base/IClusterController.java[diff]
hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/job/PartitionDescriptor.java[Added - diff]
hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/job/PartitionRequest.java[Added - diff]
hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/job/PartitionState.java[diff]
hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Joblet.java[diff]
hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/NodeControllerService.java[diff]
hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/Task.java[diff]
hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/partitions/MaterializedPartitionWriter.java[diff]
hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/partitions/PartitionManager.java[diff]
hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/partitions/PipelinedPartition.java[diff]
hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/partitions/ReceiveSideMaterializingCollector.java[diff]

28 files changed