Jet.cc

Go to the documentation of this file.

//
//

#include "DataFormats/PatCandidates/interface/Jet.h"
#include "DataFormats/RecoCandidate/interface/RecoCaloTowerCandidate.h"
#include "DataFormats/ParticleFlowCandidate/interface/PFCandidate.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"

using namespace pat;

Jet::Jet() :
  PATObject<reco::Jet>(reco::Jet()),
  embeddedCaloTowers_(false),
  embeddedPFCandidates_(false),
  jetCharge_(0.)
{
}

Jet::Jet(const reco::Jet & aJet) :
  PATObject<reco::Jet>(aJet),
  embeddedCaloTowers_(false),
  embeddedPFCandidates_(false),
  jetCharge_(0.0)
{
  tryImportSpecific(aJet);
}

Jet::Jet(const edm::Ptr<reco::Jet> & aJetRef) :
  PATObject<reco::Jet>(aJetRef),
  embeddedCaloTowers_(false),
  embeddedPFCandidates_(false),
  jetCharge_(0.0)
{
  tryImportSpecific(*aJetRef);
}

Jet::Jet(const edm::RefToBase<reco::Jet> & aJetRef) :
  PATObject<reco::Jet>(aJetRef),
  embeddedCaloTowers_(false),
  embeddedPFCandidates_(false),
  jetCharge_(0.0)
{
  tryImportSpecific(*aJetRef);
}

Jet::Jet(const edm::RefToBase<pat::Jet> & aJetRef) :
  Jet(*aJetRef)
{
  refToOrig_ = edm::Ptr<reco::Candidate>(aJetRef.id(), aJetRef.get(), aJetRef.key());
}

Jet::Jet(const edm::Ptr<pat::Jet> & aJetRef) :
  Jet(*aJetRef)
{
  refToOrig_ = aJetRef;
}

std::ostream& 
reco::operator<<(std::ostream& out, const pat::Jet& obj) 
{
  if(!out) return out;
  
  out << "\tpat::Jet: ";
  out << std::setiosflags(std::ios::right);
  out << std::setiosflags(std::ios::fixed);
  out << std::setprecision(3);
  out << " E/pT/eta/phi " 
      << obj.energy()<<"/"
      << obj.pt()<<"/"
      << obj.eta()<<"/"
      << obj.phi();
  return out; 
}

void Jet::tryImportSpecific(const reco::Jet& source)
{
  const std::type_info & type = typeid(source);
  if( type == typeid(reco::CaloJet) ){
    specificCalo_.push_back( (static_cast<const reco::CaloJet&>(source)).getSpecific() );
  } else if( type == typeid(reco::JPTJet) ){
    reco::JPTJet const & jptJet = static_cast<reco::JPTJet const &>(source);
    specificJPT_.push_back( jptJet.getSpecific() );
    reco::CaloJet const * caloJet = nullptr;
    if ( jptJet.getCaloJetRef().isNonnull() && jptJet.getCaloJetRef().isAvailable() ) {
      caloJet = dynamic_cast<reco::CaloJet const *>( jptJet.getCaloJetRef().get() );
    }
    if ( caloJet != nullptr ) {
      specificCalo_.push_back( caloJet->getSpecific() );
    }
    else {
      edm::LogWarning("OptionalProductNotFound") << " in pat::Jet, Attempted to add Calo Specifics to JPT Jets, but failed."
                         << " Jet ID for JPT Jets will not be available for you." << std::endl;
    }
  } else if( type == typeid(reco::PFJet) ){
    specificPF_.push_back( (static_cast<const reco::PFJet&>(source)).getSpecific() );
  }
}

Jet::~Jet() {
}


CaloTowerPtr Jet::getCaloConstituent (unsigned fIndex) const {
    if (embeddedCaloTowers_) {
      // Refactorized PAT access
      if ( !caloTowersFwdPtr_.empty() ) {
    return (fIndex < caloTowersFwdPtr_.size() ?
        caloTowersFwdPtr_[fIndex].ptr() : CaloTowerPtr());
      }
      // Compatibility PAT access
      else {
    if ( !caloTowers_.empty() ) {
      return (fIndex < caloTowers_.size() ?
          CaloTowerPtr(&caloTowers_, fIndex) : CaloTowerPtr());

    }
      }
    }
    // Non-embedded access
    else {
      Constituent dau = daughterPtr (fIndex);
      const CaloTower* caloTower = dynamic_cast <const CaloTower*> (dau.get());
      if (caloTower != nullptr) {
    return CaloTowerPtr(dau.id(), caloTower, dau.key() );
      }
      else {
    throw cms::Exception("Invalid Constituent") << "CaloJet constituent is not of CaloTower type";
      }

    }

    return CaloTowerPtr ();
}



std::vector<CaloTowerPtr> const & Jet::getCaloConstituents () const {
  if ( !caloTowersTemp_.isSet() || !caloTowers_.empty() ) cacheCaloTowers();
  return *caloTowersTemp_;
}



reco::PFCandidatePtr Jet::getPFConstituent (unsigned fIndex) const {
    if (embeddedPFCandidates_) {
      // Refactorized PAT access
      if ( !pfCandidatesFwdPtr_.empty() ) {
    return (fIndex < pfCandidatesFwdPtr_.size() ?
        pfCandidatesFwdPtr_[fIndex].ptr() : reco::PFCandidatePtr());
      }
      // Compatibility PAT access
      else {
    if ( !pfCandidates_.empty() ) {
      return (fIndex < pfCandidates_.size() ?
          reco::PFCandidatePtr(&pfCandidates_, fIndex) : reco::PFCandidatePtr());

    }
      }
    }
    // Non-embedded access
    else {
      Constituent dau = daughterPtr (fIndex);
      const reco::PFCandidate* pfCandidate = dynamic_cast <const reco::PFCandidate*> (dau.get());
      if (pfCandidate) {
    return reco::PFCandidatePtr(dau.id(), pfCandidate, dau.key() );
      }
      else {
    throw cms::Exception("Invalid Constituent") << "PFJet constituent is not of PFCandidate type";
      }

    }

    return reco::PFCandidatePtr ();
}

std::vector<reco::PFCandidatePtr> const & Jet::getPFConstituents () const {
  if ( !pfCandidatesTemp_.isSet() || !pfCandidates_.empty() ) cachePFCandidates();
  return *pfCandidatesTemp_;
}

const reco::Candidate * Jet::daughter(size_t i) const {
  if (isCaloJet() || isJPTJet() ) {
    if ( embeddedCaloTowers_ ) {
      if ( !caloTowersFwdPtr_.empty() ) return caloTowersFwdPtr_[i].get();
      else if ( !caloTowers_.empty() ) return &caloTowers_[i];
      else return reco::Jet::daughter(i);
    }
  }
  if (isPFJet()) {
    if ( embeddedPFCandidates_ ) {
      if ( !pfCandidatesFwdPtr_.empty() ) return pfCandidatesFwdPtr_[i].get();
      else if ( !pfCandidates_.empty() ) return &pfCandidates_[i];
      else return reco::Jet::daughter(i);
    }
  }
  if ( !subjetCollections_.empty() ) {
    if ( !daughtersTemp_.isSet() ) cacheDaughters();
    return daughtersTemp_->at(i).get();
  }
  return reco::Jet::daughter(i);
}

reco::CandidatePtr Jet::daughterPtr( size_t i ) const {
  if ( !subjetCollections_.empty() ) {
    if ( !daughtersTemp_.isSet() ) cacheDaughters();
    return daughtersTemp_->at(i);
  }
  return reco::Jet::daughterPtr(i);
}

const reco::CompositePtrCandidate::daughters & Jet::daughterPtrVector() const {
  if ( !subjetCollections_.empty() ) {
    if ( !daughtersTemp_.isSet() ) cacheDaughters();
    return *daughtersTemp_;
  }
  return reco::Jet::daughterPtrVector();
}

size_t Jet::numberOfDaughters() const {
  if (isCaloJet() || isJPTJet()) {
    if ( embeddedCaloTowers_ ) {
      if ( !caloTowersFwdPtr_.empty() ) return caloTowersFwdPtr_.size();
      else if ( !caloTowers_.empty() ) return caloTowers_.size();
      else return reco::Jet::numberOfDaughters();
    }
  }
  if (isPFJet()) {
    if ( embeddedPFCandidates_ ) {
      if ( !pfCandidatesFwdPtr_.empty() ) return pfCandidatesFwdPtr_.size();
      else if ( !pfCandidates_.empty() ) return pfCandidates_.size();
      else return reco::Jet::numberOfDaughters();
    }
  }
  if ( !subjetCollections_.empty() ) {
    if ( !daughtersTemp_.isSet() ) cacheDaughters();
    return daughtersTemp_->size();
  }
  return reco::Jet::numberOfDaughters();
}

const reco::GenJet * Jet::genJet() const {
  if (!genJet_.empty()) return  &(genJet_.front());
  else if ( !genJetRef_.empty() ) return genJetRef_[0].get();
  else return genJetFwdRef_.get();
}

int Jet::partonFlavour() const {
  return jetFlavourInfo_.getPartonFlavour();
}

int Jet::hadronFlavour() const {
  return jetFlavourInfo_.getHadronFlavour();
}

const reco::JetFlavourInfo & Jet::jetFlavourInfo() const {
  return jetFlavourInfo_;
}


// initialize the jet to a given JEC level during creation starting from Uncorrected
void Jet::initializeJEC(unsigned int level, const JetCorrFactors::Flavor& flavor, unsigned int set)
{
  currentJECSet(set);
  currentJECLevel(level);
  currentJECFlavor(flavor);
  setP4(jec_[set].correction(level, flavor)*p4());
}

int Jet::jecSet(const std::string& set) const
{
  for(std::vector<pat::JetCorrFactors>::const_iterator corrFactor=jec_.begin(); corrFactor!=jec_.end(); ++corrFactor)
    if( corrFactor->jecSet()==set ){ return (corrFactor-jec_.begin()); }
  return -1;
}

const std::vector<std::string> Jet::availableJECSets() const
{
  std::vector<std::string> sets;
  for(std::vector<pat::JetCorrFactors>::const_iterator corrFactor=jec_.begin(); corrFactor!=jec_.end(); ++corrFactor)
    sets.push_back(corrFactor->jecSet());
  return sets;
}

const std::vector<std::string> Jet::availableJECLevels(const int& set) const
{
  return set>=0 ? jec_.at(set).correctionLabels() : std::vector<std::string>();
}

float Jet::jecFactor(const std::string& level, const std::string& flavor, const std::string& set) const
{
  for(unsigned int idx=0; idx<jec_.size(); ++idx){
    if(set.empty() || jec_.at(idx).jecSet()==set){
      if(jec_[idx].jecLevel(level)>=0){
    return jecFactor(jec_[idx].jecLevel(level), jec_[idx].jecFlavor(flavor), idx);
      }
      else{
    throw cms::Exception("InvalidRequest") << "This JEC level " << level << " does not exist. \n";
      }
    }
  }
  throw cms::Exception("InvalidRequest") << "This jet does not carry any jet energy correction factor information \n"
                     << "for a jet energy correction set with label " << set << "\n";
}

float Jet::jecFactor(const unsigned int& level, const JetCorrFactors::Flavor& flavor, const unsigned int& set) const
{
  if(!jecSetsAvailable()){
    throw cms::Exception("InvalidRequest") << "This jet does not carry any jet energy correction factor information \n";
  }
  if(!jecSetAvailable(set)){
    throw cms::Exception("InvalidRequest") << "This jet does not carry any jet energy correction factor information \n"
                       << "for a jet energy correction set with index " << set << "\n";
  }
  return jec_.at(set).correction(level, flavor)/jec_.at(currentJECSet_).correction(currentJECLevel_, currentJECFlavor_);
}

Jet Jet::correctedJet(const std::string& level, const std::string& flavor, const std::string& set) const
{
  // rescale p4 of the jet; the update of current values is
  // done within the called jecFactor function
  for(unsigned int idx=0; idx<jec_.size(); ++idx){
    if(set.empty() || jec_.at(idx).jecSet()==set){
      if(jec_[idx].jecLevel(level)>=0){
    return correctedJet(jec_[idx].jecLevel(level), jec_[idx].jecFlavor(flavor), idx);
      }
      else{
    throw cms::Exception("InvalidRequest") << "This JEC level " << level << " does not exist. \n";
      }
    }
  }
  throw cms::Exception("InvalidRequest") << "This JEC set " << set << " does not exist. \n";
}

Jet Jet::correctedJet(const unsigned int& level, const JetCorrFactors::Flavor& flavor, const unsigned int& set) const
{
  Jet correctedJet(*this);
  //rescale p4 of the jet
  correctedJet.setP4(jecFactor(level, flavor, set)*p4());
  // update current level, flavor and set
  correctedJet.currentJECSet(set); correctedJet.currentJECLevel(level); correctedJet.currentJECFlavor(flavor);
  return correctedJet;
}



const std::vector<std::pair<std::string, float> > & Jet::getPairDiscri() const {
   return pairDiscriVector_;
}

float Jet::bDiscriminator(const std::string & aLabel) const {
  float discriminator = -1000.;
  for(int i=(int(pairDiscriVector_.size())-1); i>=0; i--){
    if(pairDiscriVector_[i].first == aLabel){
      discriminator = pairDiscriVector_[i].second;
      break;
    }
  }
  return discriminator;
}

const reco::BaseTagInfo * Jet::tagInfo(const std::string &label) const {
  for(int i=(int(tagInfoLabels_.size())-1); i>=0; i--){
    if (tagInfoLabels_[i] == label) {
      if ( !tagInfosFwdPtr_.empty() ) return tagInfosFwdPtr_[i].get();
      else if ( !tagInfos_.empty() )  return & tagInfos_[i];
      return nullptr;
    }
  }
  return nullptr;
}


const reco::CandIPTagInfo *
Jet::tagInfoCandIP(const std::string &label) const {
    return tagInfoByTypeOrLabel<reco::CandIPTagInfo>(label);
}

const reco::TrackIPTagInfo *
Jet::tagInfoTrackIP(const std::string &label) const {
    return tagInfoByTypeOrLabel<reco::TrackIPTagInfo>(label);
}

const reco::CandSoftLeptonTagInfo *
Jet::tagInfoCandSoftLepton(const std::string &label) const {
    return tagInfoByTypeOrLabel<reco::CandSoftLeptonTagInfo>(label);
}

const reco::SoftLeptonTagInfo *
Jet::tagInfoSoftLepton(const std::string &label) const {
    return tagInfoByTypeOrLabel<reco::SoftLeptonTagInfo>(label);
}

const reco::CandSecondaryVertexTagInfo *
Jet::tagInfoCandSecondaryVertex(const std::string &label) const {
    return tagInfoByTypeOrLabel<reco::CandSecondaryVertexTagInfo>(label);
}

const reco::SecondaryVertexTagInfo *
Jet::tagInfoSecondaryVertex(const std::string &label) const {
    return tagInfoByTypeOrLabel<reco::SecondaryVertexTagInfo>(label);
}

const reco::BoostedDoubleSVTagInfo *
Jet::tagInfoBoostedDoubleSV(const std::string &label) const {
    return tagInfoByTypeOrLabel<reco::BoostedDoubleSVTagInfo>(label);
}

void
Jet::addTagInfo(const std::string &label,
        const TagInfoFwdPtrCollection::value_type &info) {
    std::string::size_type idx = label.find("TagInfos");
    if (idx == std::string::npos) {
      tagInfoLabels_.push_back(label);
    } else {
        tagInfoLabels_.push_back(label.substr(0,idx));
    }
    tagInfosFwdPtr_.push_back(info);
}



float Jet::jetCharge() const {
  return jetCharge_;
}

const reco::TrackRefVector & Jet::associatedTracks() const {
  return associatedTracks_;
}

void Jet::setAssociatedTracks(const reco::TrackRefVector &tracks) {
    associatedTracks_ = tracks;
}

void Jet::setCaloTowers(const CaloTowerFwdPtrCollection & caloTowers) {
  caloTowersFwdPtr_.reserve(caloTowers.size());
  for(auto const& tower : caloTowers) {
    caloTowersFwdPtr_.push_back( tower );
  }
  embeddedCaloTowers_ = true;
  caloTowersTemp_.reset();
}


void Jet::setPFCandidates(const PFCandidateFwdPtrCollection & pfCandidates) {
  pfCandidatesFwdPtr_.reserve(pfCandidates.size());
  for(auto const& cand : pfCandidates) {
    pfCandidatesFwdPtr_.push_back(cand);
  }
  embeddedPFCandidates_ = true;
  pfCandidatesTemp_.reset();
}


void Jet::setGenJetRef(const edm::FwdRef<reco::GenJetCollection> & gj)
{
  genJetFwdRef_ = gj;
}



void Jet::setPartonFlavour(int partonFl) {
  jetFlavourInfo_.setPartonFlavour(partonFl);
}

void Jet::setHadronFlavour(int hadronFl) {
  jetFlavourInfo_.setHadronFlavour(hadronFl);
}

void Jet::setJetFlavourInfo(const reco::JetFlavourInfo & jetFlavourInfo) {
  jetFlavourInfo_ = jetFlavourInfo;
}

void Jet::addBDiscriminatorPair(const std::pair<std::string, float> & thePair) {
  pairDiscriVector_.push_back(thePair);
}

void Jet::setJetCharge(float jetCharge) {
  jetCharge_ = jetCharge;
}



void Jet::cacheCaloTowers() const {
  // Clear the cache
  // Here is where we've embedded constituents
  std::unique_ptr<std::vector<CaloTowerPtr>> caloTowersTemp{ new std::vector<CaloTowerPtr>{}};
  if ( embeddedCaloTowers_ ) {
    // Refactorized PAT access
    if ( !caloTowersFwdPtr_.empty() ) {
      caloTowersTemp->reserve(caloTowersFwdPtr_.size());
      for ( CaloTowerFwdPtrVector::const_iterator ibegin=caloTowersFwdPtr_.begin(),
          iend = caloTowersFwdPtr_.end(),
          icalo = ibegin;
        icalo != iend; ++icalo ) {
    caloTowersTemp->emplace_back( icalo->ptr()  );
      }
    }
    // Compatibility access
    else if ( !caloTowers_.empty() ) {
      caloTowersTemp->reserve(caloTowers_.size());
      for ( CaloTowerCollection::const_iterator ibegin=caloTowers_.begin(),
          iend = caloTowers_.end(),
          icalo = ibegin;
        icalo != iend; ++icalo ) {
    caloTowersTemp->emplace_back( &caloTowers_, icalo - ibegin  );
      }
    }
  }
  // Non-embedded access
  else {
    const auto nDaughters = numberOfDaughters();
    caloTowersTemp->reserve(nDaughters);    
    for ( unsigned fIndex = 0; fIndex < nDaughters; ++fIndex ) {
      Constituent const & dau = daughterPtr (fIndex);
      const CaloTower* caloTower = dynamic_cast <const CaloTower*> (dau.get());
      if (caloTower) {
    caloTowersTemp->emplace_back( dau.id(), caloTower,dau.key()  );
      }
      else {
    throw cms::Exception("Invalid Constituent") << "CaloJet constituent is not of CaloTower type";
      }
    }
  }
  caloTowersTemp_.set(std::move(caloTowersTemp));
}

void Jet::cachePFCandidates() const {

  std::unique_ptr<std::vector<reco::PFCandidatePtr>> pfCandidatesTemp{ new std::vector<reco::PFCandidatePtr>{}};
  // Here is where we've embedded constituents
  if ( embeddedPFCandidates_ ) {
    // Refactorized PAT access
    if ( !pfCandidatesFwdPtr_.empty() ) {
      pfCandidatesTemp->reserve(pfCandidatesFwdPtr_.size());
      for ( PFCandidateFwdPtrCollection::const_iterator ibegin=pfCandidatesFwdPtr_.begin(),
          iend = pfCandidatesFwdPtr_.end(),
          ipf = ibegin;
        ipf != iend; ++ipf ) {
    pfCandidatesTemp->emplace_back( ipf->ptr()  );
      }
    }
    // Compatibility access
    else if ( !pfCandidates_.empty() ) {
      pfCandidatesTemp->reserve(pfCandidates_.size());
      for ( reco::PFCandidateCollection::const_iterator ibegin=pfCandidates_.begin(),
          iend = pfCandidates_.end(),
          ipf = ibegin;
        ipf != iend; ++ipf ) {
    pfCandidatesTemp->emplace_back( &pfCandidates_, ipf - ibegin  );
      }
    }
  }
  // Non-embedded access
  else {
    const auto nDaughters = numberOfDaughters();
    pfCandidatesTemp->reserve(nDaughters);
    for ( unsigned fIndex = 0; fIndex < nDaughters; ++fIndex ) {
      Constituent const & dau = daughterPtr (fIndex);
      const reco::PFCandidate* pfCandidate = dynamic_cast <const reco::PFCandidate*> (dau.get());
      if (pfCandidate) {
    pfCandidatesTemp->emplace_back( dau.id(), pfCandidate,dau.key() );
      }
      else {
    throw cms::Exception("Invalid Constituent") << "PFJet constituent is not of PFCandidate type";
      }
    }
  }
  // Set the cache
  pfCandidatesTemp_.set(std::move(pfCandidatesTemp));
}
 
void Jet::cacheDaughters() const {
    // Jets in MiniAOD produced via JetSubstructurePacker contain a mixture of subjets and particles as daughters
    std::unique_ptr<std::vector<reco::CandidatePtr>> daughtersTemp{ new std::vector<reco::CandidatePtr>{}};
    const std::vector<reco::CandidatePtr> & jdaus = reco::Jet::daughterPtrVector();
    for (const reco::CandidatePtr & dau : jdaus) {
      if (dau->isJet()) {
        const reco::Jet *subjet = dynamic_cast<const reco::Jet *>(&*dau);
        if (subjet) {
          const std::vector<reco::CandidatePtr> & sjdaus = subjet->daughterPtrVector();
          daughtersTemp->insert(daughtersTemp->end(), sjdaus.begin(), sjdaus.end());
        }
      } else
        daughtersTemp->push_back( dau );
    }
    daughtersTemp_.set(std::move(daughtersTemp));
}


pat::JetPtrCollection const & Jet::subjets( unsigned int index) const { 
  if ( index < subjetCollections_.size() ) 
    return subjetCollections_[index]; 
  else {
    throw cms::Exception("OutOfRange") << "Index " << index << " is out of range" << std::endl;
  }
}


pat::JetPtrCollection const & Jet::subjets( std::string const & label ) const { 
  auto found = find( subjetLabels_.begin(), subjetLabels_.end(), label );
  if ( found != subjetLabels_.end() ){
    auto index = std::distance( subjetLabels_.begin(), found );
    return subjetCollections_[index]; 
  }
  else {
    throw cms::Exception("SubjetsNotFound") << "Label " << label << " does not match any subjet collection" << std::endl;
  }
}

void Jet::addSubjets( pat::JetPtrCollection const & pieces, std::string const & label  ) {
  subjetCollections_.push_back( pieces );
  subjetLabels_.push_back( label );
}