3224dbadf90c47d2dc1016387a6d9971c391efb9 - asterixdb

commit	3224dbadf90c47d2dc1016387a6d9971c391efb9	[log] [tgz]
author	vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053>	Thu May 05 16:51:46 2011 +0000
committer	vinayakb <vinayakb@123451ca-8445-de46-9d55-352943316053>	Thu May 05 16:51:46 2011 +0000
tree	5f92b3de27cb7c0840a1356f42ff84837d2fbf47
parent	9d475a80108f5d871d6646bf4e6897deb7dc5c80 [diff]

Added more connector policies. Cleaned up Activity API.

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

hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/ActivityId.java[Renamed from hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/ActivityNodeId.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/IActivity.java[Renamed from hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/IActivityNode.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/IActivityGraphBuilder.java[diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/IOperatorDescriptor.java[diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/PortInstanceId.java[Deleted - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/TaskId.java[diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/connectors/IConnectorPolicy.java[Renamed from hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/job/dataflow/IConnectorPolicy.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/connectors/IConnectorPolicyAssignmentPolicy.java[Copied from hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/job/dataflow/IConnectorPolicy.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/connectors/PipelinedConnectorPolicy.java[Renamed from hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/job/dataflow/PipelinedConnectorPolicy.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/connectors/SendSideMaterializedConnectorPolicy.java[Renamed from hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/job/dataflow/SendSideMaterializedConnectorPolicy.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/connectors/SendSideMaterializedReceiveSideMaterializedConnectorPolicy.java[Copied from hyracks-control-common/src/main/java/edu/uci/ics/hyracks/control/common/job/dataflow/SendSideMaterializedConnectorPolicy.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/job/JobActivityGraph.java[diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/job/JobSpecification.java[diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/things/ISliver.java[Copied from hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/Direction.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/things/IThingDescriptor.java[Copied from hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/Direction.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/things/IThingPartition.java[Renamed from hyracks-api/src/main/java/edu/uci/ics/hyracks/api/dataflow/Direction.java - diff]
hyracks-api/src/main/java/edu/uci/ics/hyracks/api/things/ThingDescriptorId.java[Added - 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/JobActivityGraphBuilder.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/AbstractTaskLifecycleEvent.java[diff]
hyracks-control-cc/src/main/java/edu/uci/ics/hyracks/control/cc/job/manager/events/JobCreateEvent.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/remote/ops/PortMapMergingAccumulator.java[Deleted - 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-common/src/main/java/edu/uci/ics/hyracks/control/common/base/INodeController.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/partitions/MaterializedPartitionInputChannel.java[Added - diff]
hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/partitions/ReceiveSideMaterializingCollector.java[Added - diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/base/AbstractActivityNode.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/base/AbstractSingleActivityOperatorDescriptor.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/ExternalHashGroupOperatorDescriptor.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/HashGroupOperatorDescriptor.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/GraceHashJoinOperatorDescriptor.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/HybridHashJoinOperatorDescriptor.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/join/InMemoryHashJoinOperatorDescriptor.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/misc/MaterializingOperatorDescriptor.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/misc/SplitVectorOperatorDescriptor.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/sort/ExternalSortOperatorDescriptor.java[diff]
hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/sort/InMemorySortOperatorDescriptor.java[diff]
hyracks-test-support/src/main/java/edu/uci/ics/hyracks/test/support/TestUtils.java[diff]

45 files changed