falcon-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Pallavi Rao" <pallavi....@inmobi.com>
Subject Review Request 35724: Base framework of the native scheduler
Date Mon, 22 Jun 2015 08:38:20 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35724/
-----------------------------------------------------------

Review request for Falcon and Srikanth Sundarrajan.


Bugs: FALCON-1213
    https://issues.apache.org/jira/browse/FALCON-1213


Repository: falcon-git


Description
-------

The patch has the basic framework for the scheduler. Each of the individual service needs
to be implemented completely and will be done as separate JIRAs. The intention of the patch
is ensure the base framework satisfies all use cases and get any early feedback in terms of
course correction.


Diffs
-----

  common/pom.xml 36de1f5 
  common/src/main/java/org/apache/falcon/entity/EntityUtil.java b86d9d7 
  pom.xml 0689899 
  scheduler/pom.xml PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/exception/DAGEngineException.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/exception/InvalidStateTransitionException.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/exception/ServiceException.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/exception/StateStoreException.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/execution/EntityExecutor.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/execution/ExecutionInstance.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/execution/FalconExecutionService.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/execution/NotificationHandler.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/execution/ProcessExecutionInstance.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/execution/ProcessExecutor.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/FalconNotificationService.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/ServicesRegistry.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/notification/service/event/DataEvent.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/notification/service/event/Event.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/notification/service/event/JobCompletedEvent.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/event/JobScheduledEvent.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/event/TimeElapsedEvent.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/impl/DataNotificationService.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/impl/JobCompletionService.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/impl/SchedulerService.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/impl/TimeNotificationService.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/request/DataNotificationRequest.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/request/JobCompletionNotificationRequest.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/request/JobScheduleNotificationRequest.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/request/NotificationRequest.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/notification/service/request/TimeNotificationRequest.java
PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/predicate/Predicate.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/state/EntityState.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/state/EntityStateChangeHandler.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/state/ID.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/state/InstanceState.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/state/InstanceStateChangeHandler.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/state/StateMachine.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/state/StateService.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/state/store/AbstractStateStore.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/state/store/InMemoryStateStore.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/state/store/StateStore.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/workflow/engine/DAGEngine.java PRE-CREATION 
  scheduler/src/main/java/org/apache/falcon/workflow/engine/FalconWorkflowEngine.java PRE-CREATION

  scheduler/src/main/java/org/apache/falcon/workflow/engine/OozieDAGEngine.java PRE-CREATION

  scheduler/src/test/java/org/apache/falcon/execution/FalconExecutionServiceTest.java PRE-CREATION

  scheduler/src/test/java/org/apache/falcon/predicate/PredicateTest.java PRE-CREATION 
  scheduler/src/test/java/org/apache/falcon/state/EntityStateServiceTest.java PRE-CREATION

  scheduler/src/test/java/org/apache/falcon/state/InstanceStateServiceTest.java PRE-CREATION

  scheduler/src/test/resources/config/cluster/cluster-0.1.xml PRE-CREATION 
  scheduler/src/test/resources/config/feed/feed-0.1.xml PRE-CREATION 
  scheduler/src/test/resources/config/process/process-0.1.xml PRE-CREATION 

Diff: https://reviews.apache.org/r/35724/diff/


Testing
-------

New UTs have been added.


Thanks,

Pallavi Rao


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message