nodeGroupExecutionService/src/main/java/com/ge/research/semtk/services/nodeGroupExecution/NodeGroupExecutionRestController.java
@ApiOperation(
			value=	"ingest CSV data given nodegroup id",
			notes=	""
			)
	@CrossOrigin
	@RequestMapping(value="/ingestFromCsvStringsById", method=RequestMethod.POST)
	public JSONObject ingestFromCsvStringsById(@RequestBody IngestByIdCsvStrRequestBody requestBody, @RequestHeader HttpHeaders headers) {
		final String ENDPOINT_NAME="ingestFromCsvStringsById";
		HeadersManager.setHeaders(headers);
		LoggerRestClient logger = LoggerRestClient.getInstance(log_prop, ThreadAuthenticator.getThreadUserName());
		LoggerRestClient.easyLog(logger, SERVICE_NAME, ENDPOINT_NAME, "nodegroupId", requestBody.getTemplateId(), "chars", String.valueOf(requestBody.getCsvContent().length()));
    	try {
			RecordProcessResults retval = null;
			try{
				NodeGroupExecutor nodeGroupExecutor = this.getExecutor(null);		

				retval = nodeGroupExecutor.ingestFromTemplateIdAndCsvString(requestBody.getSparqlConnection(), requestBody.getTemplateId(), requestBody.getCsvContent(), requestBody.getTrackFlag(), requestBody.getOverrideBaseURI());
			}catch(Exception e){
				LoggerRestClient.easyLog(logger, SERVICE_NAME, ENDPOINT_NAME + " exception", "message", e.toString());
				retval = new RecordProcessResults(false);
				retval.addRationaleMessage(SERVICE_NAME, "ingestFromCsvStrings", e);
			} 
			return retval.toJson();
		    
		} finally {
	    	HeadersManager.clearHeaders();
	    }
	}
/**
	 * Perform ingestion using a stored nodegroup ID.
	 */
Perform ingestion using a stored nodegroup ID.
Perform ingestion using a stored nodegroup ID .
@ApiOperation(
			value=	"ingest CSV data given nodegroup id",
			notes=	""
			)
	@CrossOrigin
	@RequestMapping(value="/ingestFromCsvStringsById", method=RequestMethod.POST)
	public JSONObject ingestFromCsvStringsById(@RequestBody IngestByIdCsvStrRequestBody requestBody, @RequestHeader HttpHeaders headers) {
		final String ENDPOINT_NAME="ingestFromCsvStringsById";
		HeadersManager.setHeaders(headers);
		LoggerRestClient logger = LoggerRestClient.getInstance(log_prop, ThreadAuthenticator.getThreadUserName());
		LoggerRestClient.easyLog(logger, SERVICE_NAME, ENDPOINT_NAME, "nodegroupId", requestBody.getTemplateId(), "chars", String.valueOf(requestBody.getCsvContent().length()));
    	try {
			RecordProcessResults retval = null;
			try{
				NodeGroupExecutor nodeGroupExecutor = this.getExecutor(null);		
				retval = nodeGroupExecutor.ingestFromTemplateIdAndCsvString(requestBody.getSparqlConnection(), requestBody.getTemplateId(), requestBody.getCsvContent(), requestBody.getTrackFlag(), requestBody.getOverrideBaseURI());
			}catch(Exception e){
				LoggerRestClient.easyLog(logger, SERVICE_NAME, ENDPOINT_NAME + " exception", "message", e.toString());
				retval = new RecordProcessResults(false);
				retval.addRationaleMessage(SERVICE_NAME, "ingestFromCsvStrings", e);
			} 
			return retval.toJson();
		} finally {
	    	HeadersManager.clearHeaders();
	    }
	}
@ ApiOperation ( value = "ingest CSV data given nodegroup id" , notes = "" ) @ CrossOrigin @ RequestMapping ( value = "/ingestFromCsvStringsById" , method = RequestMethod . POST ) public JSONObject ingestFromCsvStringsById ( @ RequestBody IngestByIdCsvStrRequestBody requestBody , @ RequestHeader HttpHeaders headers ) { final String ENDPOINT_NAME = "ingestFromCsvStringsById" ; HeadersManager . setHeaders ( headers ) ; LoggerRestClient logger = LoggerRestClient . getInstance ( log_prop , ThreadAuthenticator . getThreadUserName ( ) ) ; LoggerRestClient . easyLog ( logger , SERVICE_NAME , ENDPOINT_NAME , "nodegroupId" , requestBody . getTemplateId ( ) , "chars" , String . valueOf ( requestBody . getCsvContent ( ) . length ( ) ) ) ; try { RecordProcessResults retval = null ; try { NodeGroupExecutor nodeGroupExecutor = this . getExecutor ( null ) ; retval = nodeGroupExecutor . ingestFromTemplateIdAndCsvString ( requestBody . getSparqlConnection ( ) , requestBody . getTemplateId ( ) , requestBody . getCsvContent ( ) , requestBody . getTrackFlag ( ) , requestBody . getOverrideBaseURI ( ) ) ; } catch ( Exception e ) { LoggerRestClient . easyLog ( logger , SERVICE_NAME , ENDPOINT_NAME + " exception" , "message" , e . toString ( ) ) ; retval = new RecordProcessResults ( false ) ; retval . addRationaleMessage ( SERVICE_NAME , "ingestFromCsvStrings" , e ) ; } return retval . toJson ( ) ; } finally { HeadersManager . clearHeaders ( ) ; } }
Perform ingestion using a stored nodegroup ID.
Perform ingestion using a stored nodegroup ID .