Examples of FlushRequest

org.elasticsearch.action.admin.indices.flush.FlushRequest
A flush request to flush one or more indices. The flush process of an index basically frees memory from the index by flushing data to the index storage and clearing the internal transaction log. By default, ElasticSearch uses memory heuristics in order to automatically trigger flush operations as required in order to clear memory.
Best created with {@link org.elasticsearch.client.Requests#flushRequest(String)}. @author kimchy (shay.banon) @see org.elasticsearch.client.Requests#flushRequest(String) @see org.elasticsearch.client.IndicesAdminClient#flush(FlushRequest) @see FlushResponse

Examples of org.elasticsearch.action.admin.indices.flush.FlushRequest

    @Test
    public void testFlush() {
        String flushShardAction = FlushAction.NAME + "[s]";
        interceptTransportActions(flushShardAction);


        FlushRequest flushRequest = new FlushRequest(randomIndicesOrAliases());
        internalCluster().clientNodeClient().admin().indices().flush(flushRequest).actionGet();


        clearInterceptedActions();
        assertSameIndices(flushRequest, flushShardAction);
    }

View Full Code Here

Examples of org.elasticsearch.action.admin.indices.flush.FlushRequest

    }


    @Override
    protected void masterOperation(final DeleteMappingRequest request, final ClusterState state, final ActionListener<DeleteMappingResponse> listener) throws ElasticsearchException {
        final String[] concreteIndices = state.metaData().concreteIndices(request.indicesOptions(), request.indices());
        flushAction.execute(new FlushRequest(request).indices(concreteIndices), new ActionListener<FlushResponse>() {
            @Override
            public void onResponse(FlushResponse flushResponse) {
                if (logger.isTraceEnabled()) {
                    traceLogResponse("Flush", flushResponse);
                }

View Full Code Here

Examples of org.elasticsearch.action.admin.indices.flush.FlushRequest

    /**
     * Flush an index
     * @param indexName
     */
    public static void flush(String indexName) {
        IndexClient.client.admin().indices().flush(new FlushRequest(indexName)).actionGet();
    }

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.