Skip to content

/AWS1/CL_EMR=>DESCRIBEJOBFLOWS()

About DescribeJobFlows

This API is no longer supported and will eventually be removed. We recommend you use ListClusters, DescribeCluster, ListSteps, ListInstanceGroups and ListBootstrapActions instead.

DescribeJobFlows returns a list of job flows that match all of the supplied parameters. The parameters can include a list of job flow IDs, job flow states, and restrictions on job flow creation date and time.

Regardless of supplied parameters, only job flows created within the last two months are returned.

If no parameters are supplied, then job flows matching either of the following criteria are returned:

  • Job flows created and completed in the last two weeks

  • Job flows created within the last two months that are in one of the following states: RUNNING, WAITING, SHUTTING_DOWN, STARTING

Amazon EMR can return a maximum of 512 job flow descriptions.

Method Signature

IMPORTING

Optional arguments:

iv_createdafter TYPE /AWS1/EMRDATE /AWS1/EMRDATE

Return only job flows created after this date and time.

iv_createdbefore TYPE /AWS1/EMRDATE /AWS1/EMRDATE

Return only job flows created before this date and time.

it_jobflowids TYPE /AWS1/CL_EMRXMLSTRINGLIST_W=>TT_XMLSTRINGLIST TT_XMLSTRINGLIST

Return only job flows whose job flow ID is contained in this list.

it_jobflowstates TYPE /AWS1/CL_EMRJOBFLOWEXSTATELS00=>TT_JOBFLOWEXECUTIONSTATELIST TT_JOBFLOWEXECUTIONSTATELIST

Return only job flows whose state is contained in this list.

RETURNING

oo_output TYPE REF TO /aws1/cl_emrdescrjobflowsout /AWS1/CL_EMRDESCRJOBFLOWSOUT

Domain /AWS1/RT_ACCOUNT_ID
Primitive Type NUMC

Examples

Syntax Example

This is an example of the syntax for calling the method. It includes every possible argument and initializes every possible value. The data provided is not necessarily semantically accurate (for example the value "string" may be provided for something that is intended to be an instance ID, or in some cases two arguments may be mutually exclusive). The syntax shows the ABAP syntax for creating the various data structures.

DATA(lo_result) = lo_client->/aws1/if_emr~describejobflows(
  it_jobflowids = VALUE /aws1/cl_emrxmlstringlist_w=>tt_xmlstringlist(
    ( new /aws1/cl_emrxmlstringlist_w( |string| ) )
  )
  it_jobflowstates = VALUE /aws1/cl_emrjobflowexstatels00=>tt_jobflowexecutionstatelist(
    ( new /aws1/cl_emrjobflowexstatels00( |string| ) )
  )
  iv_createdafter = '20150101000000.0000000'
  iv_createdbefore = '20150101000000.0000000'
).

This is an example of reading all possible response values

LOOP AT lo_result->get_jobflows( ) into lo_row.
  lv_xmlstringmaxlen256 = lo_row_1->get_jobflowid( ).
  lv_xmlstringmaxlen256 = lo_row_1->get_name( ).
  lv_xmlstring = lo_row_1->get_loguri( ).
  lv_xmlstring = lo_row_1->get_logencryptionkmskeyid( ).
  lv_xmlstringmaxlen256 = lo_row_1->get_amiversion( ).
  lv_jobflowexecutionstate = lo_jobflowexecutionstatusd->get_state( ).
  lv_date = lo_jobflowexecutionstatusd->get_creationdatetime( ).
  lv_date = lo_jobflowexecutionstatusd->get_startdatetime( ).
  lv_date = lo_jobflowexecutionstatusd->get_readydatetime( ).
  lv_date = lo_jobflowexecutionstatusd->get_enddatetime( ).
  lv_xmlstring = lo_jobflowexecutionstatusd->get_laststatechangereason( ).
  lv_instancetype = lo_jobflowinstancesdetail->get_masterinstancetype( ).
  lv_xmlstring = lo_jobflowinstancesdetail->get_masterpublicdnsname( ).
  lv_xmlstring = lo_jobflowinstancesdetail->get_masterinstanceid( ).
  lv_instancetype = lo_jobflowinstancesdetail->get_slaveinstancetype( ).
  lv_integer = lo_jobflowinstancesdetail->get_instancecount( ).
  LOOP AT lo_jobflowinstancesdetail->get_instancegroups( ) into lo_row_2.
    lv_xmlstringmaxlen256 = lo_row_3->get_instancegroupid( ).
    lv_xmlstringmaxlen256 = lo_row_3->get_name( ).
    lv_markettype = lo_row_3->get_market( ).
    lv_instanceroletype = lo_row_3->get_instancerole( ).
    lv_xmlstringmaxlen256 = lo_row_3->get_bidprice( ).
    lv_instancetype = lo_row_3->get_instancetype( ).
    lv_integer = lo_row_3->get_instancerequestcount( ).
    lv_integer = lo_row_3->get_instancerunningcount( ).
    lv_instancegroupstate = lo_row_3->get_state( ).
    lv_xmlstring = lo_row_3->get_laststatechangereason( ).
    lv_date = lo_row_3->get_creationdatetime( ).
    lv_date = lo_row_3->get_startdatetime( ).
    lv_date = lo_row_3->get_readydatetime( ).
    lv_date = lo_row_3->get_enddatetime( ).
    lv_xmlstringmaxlen256 = lo_row_3->get_customamiid( ).
  ENDLOOP.
  lv_integer = lo_jobflowinstancesdetail->get_normalizedinstancehours( ).
  lv_xmlstringmaxlen256 = lo_jobflowinstancesdetail->get_ec2keyname( ).
  lv_xmlstringmaxlen256 = lo_jobflowinstancesdetail->get_ec2subnetid( ).
  lv_xmlstring = lo_placementtype->get_availabilityzone( ).
  LOOP AT lo_placementtype->get_availabilityzones( ) into lo_row_4.
    lv_xmlstringmaxlen256 = lo_row_5->get_value( ).
  ENDLOOP.
  lv_boolean = lo_jobflowinstancesdetail->get_keepjobflowalivewhenno00( ).
  lv_boolean = lo_jobflowinstancesdetail->get_terminationprotected( ).
  lv_booleanobject = lo_jobflowinstancesdetail->get_unhealthynodereplacement( ).
  lv_xmlstringmaxlen256 = lo_jobflowinstancesdetail->get_hadoopversion( ).
  LOOP AT lo_row_1->get_steps( ) into lo_row_6.
    lv_xmlstringmaxlen256 = lo_stepconfig->get_name( ).
    lv_actiononfailure = lo_stepconfig->get_actiononfailure( ).
    LOOP AT lo_hadoopjarstepconfig->get_properties( ) into lo_row_8.
      lv_xmlstring = lo_row_9->get_key( ).
      lv_xmlstring = lo_row_9->get_value( ).
    ENDLOOP.
    lv_xmlstring = lo_hadoopjarstepconfig->get_jar( ).
    lv_xmlstring = lo_hadoopjarstepconfig->get_mainclass( ).
    LOOP AT lo_hadoopjarstepconfig->get_args( ) into lo_row_10.
      lv_xmlstring = lo_row_11->get_value( ).
    ENDLOOP.
    lv_stepexecutionstate = lo_stepexecutionstatusdeta->get_state( ).
    lv_date = lo_stepexecutionstatusdeta->get_creationdatetime( ).
    lv_date = lo_stepexecutionstatusdeta->get_startdatetime( ).
    lv_date = lo_stepexecutionstatusdeta->get_enddatetime( ).
    lv_xmlstring = lo_stepexecutionstatusdeta->get_laststatechangereason( ).
  ENDLOOP.
  LOOP AT lo_row_1->get_bootstrapactions( ) into lo_row_12.
    lv_xmlstringmaxlen256 = lo_bootstrapactionconfig->get_name( ).
    lv_xmlstring = lo_scriptbootstrapactionco->get_path( ).
    LOOP AT lo_scriptbootstrapactionco->get_args( ) into lo_row_10.
      lv_xmlstring = lo_row_11->get_value( ).
    ENDLOOP.
  ENDLOOP.
  LOOP AT lo_row_1->get_supportedproducts( ) into lo_row_14.
    lv_xmlstringmaxlen256 = lo_row_15->get_value( ).
  ENDLOOP.
  lv_boolean = lo_row_1->get_visibletoallusers( ).
  lv_xmlstring = lo_row_1->get_jobflowrole( ).
  lv_xmlstring = lo_row_1->get_servicerole( ).
  lv_xmlstring = lo_row_1->get_autoscalingrole( ).
  lv_scaledownbehavior = lo_row_1->get_scaledownbehavior( ).
ENDLOOP.