public void sendMessage(String type,String key,String value){
  if (type.equals(SET_CONFIG_TYPE)) {
    sendSetConfigMessage(key,value);
  }
 else {
    throw new IllegalArgumentException("Type is invalid. The possible values are {" + SET_CONFIG_TYPE + "}");
  }
}

public void sendMessage ( String type , String key , String value ) { if ( type . equals ( SET_CONFIG_TYPE ) ) { sendSetConfigMessage ( key , value ) ; } else { throw new IllegalArgumentException ( "Type is invalid. The possible values are {" + SET_CONFIG_TYPE + "}" ) ; } }
this method sends a message to the coordinator stream . this creates a message containing ( type , key , value ) . for example if you want to set the number of yarn containers to 3 , you would use ( " set - config " , " yarn . container . count " , " 3 " ) .
