Project

General

Profile

« Previous | Next » 

Revision 57634

Added by Claudio Atzori over 4 years ago

[broker] factored out method to obtain the key to be emitted by the enrichment map phase

View differences:

ProjectEnrichmentMapper.java
63 63 
			} else if (DedupUtils.isRoot(key)) {
64 64 
				emit(context, key.copyBytes(), oafBuilder.build().toByteArray(), "result merges");
65 65 
			} else {
66 
				emit(context, getRootId(mergedIn), oafBuilder.build().toByteArray(), "result mergedIn");
66 
				emit(context, getEmitKey(context, key, mergedIn), oafBuilder.build().toByteArray(), "result mergedIn");
67 67 
			}
68 68 

  		




  69
  69
  
    
			break;


  		




  ......




  111
  111
  
    
		return OafRowKeyDecoder.decode(key.copyBytes()).getType();


  		




  112
  112
  
    
	}


  		




  113
  113
  
    

  		




  114
  
  
    
	private byte[] getRootId(final Map<byte[], byte[]> mergedIn) {


  		




  115
  
  
    
		return Iterables.getOnlyElement(mergedIn.keySet());


  		




  116
  
  
    
	}


  		




  117
  
  
    

  		




  118
  114
  
    
}


  		












Also available in:  Unified diff