public static void main ( final String [ ] args ) throws InjectionException { try ( final REEFEnvironment reef = REEFEnvironment . fromConfiguration ( LOCAL_DRIVER_MODULE , DRIVER_CONFIG , ENVIRONMENT_CONFIG ) ) { reef . run ( ) ; final ReefServiceProtos . JobStatusProto status = reef . getLastStatus ( ) ; LOG . log ( Level . INFO , "REEF job completed: {0}" , status ) ; } }
Start Hello REEF job with Driver and Client sharing the same process .