net.bluemind.lib.elasticsearch

Class ESearchActivator

java.lang.Object

net.bluemind.lib.elasticsearch.ESearchActivator

All Implemented Interfaces:

org.osgi.framework.BundleActivator

public final class ESearchActivator
extends java.lang.Object
implements org.osgi.framework.BundleActivator

Constructor Summary

Constructors

Constructor and Description
ESearchActivator()

Method Summary

Modifier and Type	Method and Description
static void	addAliasTo(java.lang.String aliasName, java.lang.String indexName, boolean isWriteIndex)
static void	asyncIndex(java.lang.String index, java.lang.String kind, java.lang.String id, java.util.Map<java.lang.String,java.lang.Object> obj)
static void	clearClientCache()
static org.elasticsearch.client.Client	createClient(java.util.Collection<java.lang.String> hosts)
static void	delete(java.lang.String index, java.lang.String kind, java.lang.String id)
static void	deleteByQuery(java.lang.String index, org.elasticsearch.index.query.QueryBuilder query)
static void	deleteByQuery(java.lang.String index, java.lang.String query)
static void	disableFlush(java.lang.String... indexes)
static void	enableFlush(java.lang.String... indexes)
static void	flush(java.lang.String index)
static org.elasticsearch.client.Client	getClient()
static org.elasticsearch.client.Client	getClient(java.lang.String tag)
static byte[]	getIndexSchema(java.lang.String indexName)
static void	index(java.lang.String index, java.lang.String kind, java.lang.String id, java.util.Map<java.lang.String,java.lang.Object> obj)
static void	initClasspath()
static void	initClient(org.elasticsearch.client.Client client)
static void	initIndex(org.elasticsearch.client.Client client, java.lang.String index, boolean primary)
static org.elasticsearch.action.search.SearchRequestBuilder	prepareSearch(java.lang.String index, org.elasticsearch.index.query.QueryBuilder query)
static org.elasticsearch.action.search.SearchRequestBuilder	prepareSearch(java.lang.String index, java.lang.String query)
static void	refreshIndex(java.lang.String index)
static void	resetAll()
static void	resetIndex(java.lang.String index)
static void	resetIndexes()
static org.elasticsearch.search.SearchHits	search(java.lang.String index, java.lang.String query)
static org.elasticsearch.search.SearchHits	search(java.lang.String index, java.lang.String query, int from, int size)
static org.elasticsearch.search.SearchHits	search(java.lang.String index, java.lang.String query, int from, int size, java.lang.String field)
void	start(org.osgi.framework.BundleContext bundleContext)
void	stop(org.osgi.framework.BundleContext bundleContext)
static void	update(java.lang.String index, java.lang.String kind, java.lang.String id, java.lang.String field, java.lang.Object value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ESearchActivator

public ESearchActivator()

Method Detail

start

public void start(org.osgi.framework.BundleContext bundleContext)
           throws java.lang.Exception

Specified by:

start in interface org.osgi.framework.BundleActivator

Throws:

java.lang.Exception

stop

public void stop(org.osgi.framework.BundleContext bundleContext)
          throws java.lang.Exception

Specified by:

stop in interface org.osgi.framework.BundleActivator

Throws:

java.lang.Exception

initClient

public static final void initClient(org.elasticsearch.client.Client client)

initClasspath

public static final void initClasspath()

index

public static final void index(java.lang.String index,
                               java.lang.String kind,
                               java.lang.String id,
                               java.util.Map<java.lang.String,java.lang.Object> obj)

asyncIndex

public static final void asyncIndex(java.lang.String index,
                                    java.lang.String kind,
                                    java.lang.String id,
                                    java.util.Map<java.lang.String,java.lang.Object> obj)

delete

public static final void delete(java.lang.String index,
                                java.lang.String kind,
                                java.lang.String id)

deleteByQuery

public static final void deleteByQuery(java.lang.String index,
                                       java.lang.String query)

deleteByQuery

public static final void deleteByQuery(java.lang.String index,
                                       org.elasticsearch.index.query.QueryBuilder query)

search

public static final org.elasticsearch.search.SearchHits search(java.lang.String index,
                                                               java.lang.String query)

search

public static final org.elasticsearch.search.SearchHits search(java.lang.String index,
                                                               java.lang.String query,
                                                               int from,
                                                               int size)

search

public static final org.elasticsearch.search.SearchHits search(java.lang.String index,
                                                               java.lang.String query,
                                                               int from,
                                                               int size,
                                                               java.lang.String field)

prepareSearch

public static org.elasticsearch.action.search.SearchRequestBuilder prepareSearch(java.lang.String index,
                                                                                 java.lang.String query)

prepareSearch

public static org.elasticsearch.action.search.SearchRequestBuilder prepareSearch(java.lang.String index,
                                                                                 org.elasticsearch.index.query.QueryBuilder query)

update

public static final void update(java.lang.String index,
                                java.lang.String kind,
                                java.lang.String id,
                                java.lang.String field,
                                java.lang.Object value)

getClient

public static org.elasticsearch.client.Client getClient(java.lang.String tag)

getClient

public static org.elasticsearch.client.Client getClient()

createClient

public static org.elasticsearch.client.Client createClient(java.util.Collection<java.lang.String> hosts)

refreshIndex

public static void refreshIndex(java.lang.String index)

disableFlush

public static void disableFlush(java.lang.String... indexes)

enableFlush

public static void enableFlush(java.lang.String... indexes)

flush

public static void flush(java.lang.String index)

resetAll

public static void resetAll()

resetIndex

public static void resetIndex(java.lang.String index)

addAliasTo

public static void addAliasTo(java.lang.String aliasName,
                              java.lang.String indexName,
                              boolean isWriteIndex)

initIndex

public static void initIndex(org.elasticsearch.client.Client client,
                             java.lang.String index,
                             boolean primary)

getIndexSchema

public static byte[] getIndexSchema(java.lang.String indexName)

resetIndexes

public static void resetIndexes()

clearClientCache

public static void clearClientCache()