sparqlGraphLibrary/src/main/java/com/ge/research/semtk/api/nodeGroupExecution/client/NodeGroupExecutionClient.java
@SuppressWarnings("unchecked")
	public RecordProcessResults execIngestionFromCsvStr(SparqlGraphJson sparqlGraphJson, String csvContentStr) throws Exception {
		RecordProcessResults retval = null;
		
		conf.setServiceEndpoint(mappingPrefix + ingestFromCsvStringsAndTemplateNewConnectionEndpoint);
		this.parametersJSON.put("template", sparqlGraphJson.getJson().toJSONString());
		this.parametersJSON.put(JSON_KEY_SPARQL_CONNECTION, sparqlGraphJson.getSparqlConnJson().toJSONString());
		this.parametersJSON.put("csvContent", csvContentStr);
	
		try{
			JSONObject jobj = (JSONObject) this.execute();
			retval = new RecordProcessResults(jobj);
			retval.throwExceptionIfUnsuccessful();
		}
		finally{
			this.reset();
		}
		return retval;
	}
/**
	 * Raw call to a synchronous ingestion given nodegroup
	 * NOTE this is truly synchronous and could time out
	 * @param sparqlGraphJson
	 * @param csvContentStr
	 * @return RecordProcessResults
	 * @throws Exception
	 */
Raw call to a synchronous ingestion given nodegroup
NOTE this is truly synchronous and could time out
@param sparqlGraphJson
@param csvContentStr
@return RecordProcessResults
@throws Exception
Raw call to a synchronous ingestion given nodegroup NOTE this is truly synchronous and could time out @param sparqlGraphJson @param csvContentStr @return RecordProcessResults @throws Exception
@SuppressWarnings("unchecked")
	public RecordProcessResults execIngestionFromCsvStr(SparqlGraphJson sparqlGraphJson, String csvContentStr) throws Exception {
		RecordProcessResults retval = null;
		conf.setServiceEndpoint(mappingPrefix + ingestFromCsvStringsAndTemplateNewConnectionEndpoint);
		this.parametersJSON.put("template", sparqlGraphJson.getJson().toJSONString());
		this.parametersJSON.put(JSON_KEY_SPARQL_CONNECTION, sparqlGraphJson.getSparqlConnJson().toJSONString());
		this.parametersJSON.put("csvContent", csvContentStr);
		try{
			JSONObject jobj = (JSONObject) this.execute();
			retval = new RecordProcessResults(jobj);
			retval.throwExceptionIfUnsuccessful();
		}
		finally{
			this.reset();
		}
		return retval;
	}
@ SuppressWarnings ( "unchecked" ) public RecordProcessResults execIngestionFromCsvStr ( SparqlGraphJson sparqlGraphJson , String csvContentStr ) throws Exception { RecordProcessResults retval = null ; conf . setServiceEndpoint ( mappingPrefix + ingestFromCsvStringsAndTemplateNewConnectionEndpoint ) ; this . parametersJSON . put ( "template" , sparqlGraphJson . getJson ( ) . toJSONString ( ) ) ; this . parametersJSON . put ( JSON_KEY_SPARQL_CONNECTION , sparqlGraphJson . getSparqlConnJson ( ) . toJSONString ( ) ) ; this . parametersJSON . put ( "csvContent" , csvContentStr ) ; try { JSONObject jobj = ( JSONObject ) this . execute ( ) ; retval = new RecordProcessResults ( jobj ) ; retval . throwExceptionIfUnsuccessful ( ) ; } finally { this . reset ( ) ; } return retval ; }
Raw call to a synchronous ingestion given nodegroup
 NOTE this is truly synchronous and could time out
 @param sparqlGraphJson
 @param csvContentStr
 @return RecordProcessResults
 @throws Exception
Raw call to a synchronous ingestion given nodegroup NOTE this is truly synchronous and could time out @param sparqlGraphJson @param csvContentStr @return RecordProcessResults @throws Exception