Project

General

Profile

« Previous | Next » 

Revision 56875

Added by Miriam Baglioni almost 5 years ago

fixed error

View differences:

PropagationCommunityThroughOrganizationFileReducer.java
74 74 
        resultIds.stream().forEach(result -> {
75 75 
            try {
76 76 
                final ResultProtos.Result.Metadata.Builder metadata = ResultProtos.Result.Metadata.newBuilder();
77 
                communities.stream().forEach(community->metadata.addContext(Utils.getContext(community, ORGANIZATION_COMMUNITY_TRUST, CLASS_ORGANIZATION_ID, DATA_INFO_TYPE)));
77 
                communities.stream().forEach(community->metadata.addContext(Utils.getContext(community, ORGANIZATION_COMMUNITY_TRUST, CLASS_ORGANIZATION_ID, DATA_INFO_TYPE,CLASS_ORGANIZATION_NAME)));
78 78 

  		




  79
  79
  
    
                String keyString = Bytes.toString(key.get());


  		




  80
  80
  
    
                keyOut.set(keyString);


  		












Also available in:  Unified diff