Project

General

Profile

« Previous | Next » 

Revision 60318

Added by Claudio Atzori about 3 years ago

updated hadoop-specific aggregation workflows

View differences:

CreateMDStoreHadoopJobNode.java
3 3 
import java.util.HashMap;
4 4 
import java.util.Map;
5 5 

  		




  
  6
  
    
import com.google.gson.Gson;


  		




  6
  7
  
    
import org.apache.commons.logging.Log;


  		




  7
  8
  
    
import org.apache.commons.logging.LogFactory;


  		




  8
  9
  
    
import org.springframework.beans.factory.annotation.Required;


  		




  ......




  45
  46
  
    
                .buildAndExpand(params)


  		




  46
  47
  
    
                .toUri();


  		




  47
  48
  
    

  		




  
  49
  
    
        log.info("create mdstore request: " + uri.toString());


  		




  
  50
  
    

  		




  48
  51
  
    
        final RestTemplate restTemplate = new RestTemplate();


  		




  49
  52
  
    
        final MDStoreWithInfo result = restTemplate.getForObject(uri, MDStoreWithInfo.class);


  		




  50
  53
  
    

  		




  51
  
  
    
        log.info("mdstore created " + result.toString());


  		




  
  54
  
    
        log.info("created mdstore: " + new Gson().toJson(result));


  		




  52
  55
  
    

  		




  53
  56
  
    
        token.getEnv().setAttribute(getOutputPrefix() + "format", format);


  		




  54
  57
  
    
        token.getEnv().setAttribute(getOutputPrefix() + "layout", layout);


  		












Also available in:  Unified diff