src/main/java/org/novus/controller/IngestorController.java
/**
   * 
   * This uses the json passed to populate random predefined values and generate ES schema specific json to
   * feed into ES and ingest it into ES
   * 
   * @param esUrl
   * @param clusterName
   * @param index
   * @param type
   * @param mapping
   * @param sampleJson
   * @param startIndex
   * @param sampleSize
   * @return
   * @throws IOException
   */
This uses the json passed to populate random predefined values and generate ES schema specific json to
feed into ES and ingest it into ES


This uses the json passed to populate random predefined values and generate ES schema specific json to feed into ES and ingest it into ES
@RequestMapping(value = "/json", method = RequestMethod.POST)
  public String uploadingJsonPost(@RequestParam("esUrl") String esUrl,
      @RequestParam(value = "clusterName") String clusterName, @RequestParam(value = "index") String index,
      @RequestParam(value = "type") String type, @RequestParam(value = "mapping") String mapping,
      @RequestParam(value = "json") String sampleJson,
      @RequestParam(value = "startIndex", required = false) int startIndex,
      @RequestParam(value = "sampleSize", required = false) int sampleSize) throws IOException {
    TransportClient client = ESClient.createEsClient(clusterName, esUrl, index, mapping, restTemplate);
    ingestorService.jsonGenerator(client, sampleJson, startIndex, sampleSize, index, type);
    return "redirect:/";
  }
@ RequestMapping ( value = "/json" , method = RequestMethod . POST ) public String uploadingJsonPost ( @ RequestParam ( "esUrl" ) String esUrl , @ RequestParam ( value = "clusterName" ) String clusterName , @ RequestParam ( value = "index" ) String index , @ RequestParam ( value = "type" ) String type , @ RequestParam ( value = "mapping" ) String mapping , @ RequestParam ( value = "json" ) String sampleJson , @ RequestParam ( value = "startIndex" , required = false ) int startIndex , @ RequestParam ( value = "sampleSize" , required = false ) int sampleSize ) throws IOException { TransportClient client = ESClient . createEsClient ( clusterName , esUrl , index , mapping , restTemplate ) ; ingestorService . jsonGenerator ( client , sampleJson , startIndex , sampleSize , index , type ) ; return "redirect:/" ; }
This uses the json passed to populate random predefined values and generate ES schema specific json to
 feed into ES and ingest it into ES
This uses the json passed to populate random predefined values and generate ES schema specific json to feed into ES and ingest it into ES