lib/src/kbasesearchengine/search/ElasticIndexingStorage.java
public Response makeRequestBulk(
            final String reqType,
            final String indexName,
            final File jsonData) 
            throws IOException, IndexingConflictException {
        try (InputStream is = new FileInputStream(jsonData)) {
            return makeRequest(reqType, "/" + indexName + "/_bulk?refresh=wait_for", Collections.emptyMap(),
                    new InputStreamEntity(is));
        }
    }
/**
     * This method causes an immediate refresh of the indexed objects.
     *
     * @param reqType
     * @param indexName
     * @param jsonData
     * @return
     * @throws IOException
     * @throws IndexingConflictException
     */
This method causes an immediate refresh of the indexed objects.
This method causes an immediate refresh of the indexed objects .
public Response makeRequestBulk(
            final String reqType,
            final String indexName,
            final File jsonData) 
            throws IOException, IndexingConflictException {
        try (InputStream is = new FileInputStream(jsonData)) {
            return makeRequest(reqType, "/" + indexName + "/_bulk?refresh=wait_for", Collections.emptyMap(),
                    new InputStreamEntity(is));
        }
    }
public Response makeRequestBulk ( final String reqType , final String indexName , final File jsonData ) throws IOException , IndexingConflictException { try ( InputStream is = new FileInputStream ( jsonData ) ) { return makeRequest ( reqType , "/" + indexName + "/_bulk?refresh=wait_for" , Collections . emptyMap ( ) , new InputStreamEntity ( is ) ) ; } }
This method causes an immediate refresh of the indexed objects.
This method causes an immediate refresh of the indexed objects .