@ Override public Entity toEntity ( ) { Entity entity = toProtoEntity ( ) ; entity . setProperty ( JOB_INSTANCE_PROPERTY , jobInstanceKey ) ; entity . setProperty ( FINALIZE_BARRIER_PROPERTY , finalizeBarrierKey ) ; entity . setProperty ( RUN_BARRIER_PROPERTY , runBarrierKey ) ; entity . setProperty ( OUTPUT_SLOT_PROPERTY , outputSlotKey ) ; entity . setProperty ( STATE_PROPERTY , state . toString ( ) ) ; if ( null != exceptionHandlingAncestorKey ) { entity . setProperty ( EXCEPTION_HANDLING_ANCESTOR_KEY_PROPERTY , exceptionHandlingAncestorKey ) ; } if ( exceptionHandlerSpecified ) { entity . setProperty ( EXCEPTION_HANDLER_SPECIFIED_PROPERTY , Boolean . TRUE ) ; } if ( null != exceptionHandlerJobKey ) { entity . setProperty ( EXCEPTION_HANDLER_JOB_KEY_PROPERTY , exceptionHandlerJobKey ) ; } if ( null != exceptionKey ) { entity . setProperty ( EXCEPTION_KEY_PROPERTY , exceptionKey ) ; } if ( null != exceptionHandlerJobGraphGuid ) { entity . setUnindexedProperty ( EXCEPTION_HANDLER_JOB_GRAPH_GUID_PROPERTY , new Text ( exceptionHandlerJobGraphGuid ) ) ; } entity . setUnindexedProperty ( CALL_EXCEPTION_HANDLER_PROPERTY , callExceptionHandler ) ; entity . setUnindexedProperty ( IGNORE_EXCEPTION_PROPERTY , ignoreException ) ; if ( childGraphGuid != null ) { entity . setUnindexedProperty ( CHILD_GRAPH_GUID_PROPERTY , new Text ( childGraphGuid ) ) ; } entity . setProperty ( START_TIME_PROPERTY , startTime ) ; entity . setUnindexedProperty ( END_TIME_PROPERTY , endTime ) ; entity . setProperty ( CHILD_KEYS_PROPERTY , childKeys ) ; entity . setUnindexedProperty ( ATTEMPT_NUM_PROPERTY , attemptNumber ) ; entity . setUnindexedProperty ( MAX_ATTEMPTS_PROPERTY , maxAttempts ) ; entity . setUnindexedProperty ( BACKOFF_SECONDS_PROPERTY , backoffSeconds ) ; entity . setUnindexedProperty ( BACKOFF_FACTOR_PROPERTY , backoffFactor ) ; entity . setUnindexedProperty ( ON_BACKEND_PROPERTY , queueSettings . getOnBackend ( ) ) ; entity . setUnindexedProperty ( ON_MODULE_PROPERTY , queueSettings . getOnModule ( ) ) ; entity . setUnindexedProperty ( MODULE_VERSION_PROPERTY , queueSettings . getModuleVersion ( ) ) ; entity . setUnindexedProperty ( ON_QUEUE_PROPERTY , queueSettings . getOnQueue ( ) ) ; entity . setUnindexedProperty ( STATUS_CONSOLE_URL , statusConsoleUrl ) ; if ( rootJobDisplayName != null ) { entity . setProperty ( ROOT_JOB_DISPLAY_NAME , rootJobDisplayName ) ; } return entity ; }
Constructs and returns a Data Store Entity that represents this model object