本文整理汇总了Java中org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder类的典型用法代码示例。如果您正苦于以下问题：Java RefreshRequestBuilder类的具体用法？Java RefreshRequestBuilder怎么用？Java RefreshRequestBuilder使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
RefreshRequestBuilder类属于org.elasticsearch.action.admin.indices.refresh包，在下文中一共展示了RefreshRequestBuilder类的15个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testRefreshIndex
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@Test
public void testRefreshIndex() {
// Test data
final String indexName = "Index_Name";
final AdminClient adminClient = createMock(AdminClient.class);
final IndicesAdminClient indicesAdminClient = createMock(IndicesAdminClient.class);
final RefreshRequestBuilder refreshRequestBuilder = createMock(RefreshRequestBuilder.class);
final PutMappingResponse putMappingResponse = createMock(PutMappingResponse.class);
// Reset
resetAll();
// Expectations
expect(esClient.admin()).andReturn(adminClient);
expect(adminClient.indices()).andReturn(indicesAdminClient);
expect(indicesAdminClient.prepareRefresh(indexName)).andReturn(refreshRequestBuilder);
expect(refreshRequestBuilder.get()).andReturn(createMock(RefreshResponse.class));
// Replay
replayAll();
// Run test scenario
elasticsearchClientWrapper.refreshIndex(indexName);
// Verify
verifyAll();
}
开发者ID:Biacode，项目名称:escommons，代码行数:23，代码来源:ElasticsearchClientWrapperImplTest.java
示例2: call
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@Override
public Observable<PersistentContainer> call(PersistentContainer persistentContainer) {
Elasticsearch elasticsearch = vertxContext.verticle().elasticsearch();
String objectIndexName = elasticsearch.objectIndex(persistentContainer.getName());
return aVoid()
.flatMap(names -> {
RefreshRequestBuilder request =
elasticsearch
.get()
.admin()
.indices()
.prepareRefresh(objectIndexName);
return elasticsearch.execute(vertxContext, request, elasticsearch.getDefaultAdminTimeout())
.map(refreshResponseOptional -> persistentContainer);
});
}
开发者ID:pitchpoint-solutions，项目名称:sfs，代码行数:19，代码来源:ObjectIndexRefresh.java
示例3: call
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@Override
public Observable<Void> call(Void aVoid) {
Elasticsearch elasticsearch = vertxContext.verticle().elasticsearch();
return aVoid()
.flatMap(new ListSfsIndexes(vertxContext))
.flatMap(name -> {
RefreshRequestBuilder request =
elasticsearch
.get()
.admin()
.indices()
.prepareRefresh(name);
return elasticsearch.execute(vertxContext, request, elasticsearch.getDefaultAdminTimeout())
.map(refreshResponseOptional -> null);
})
.count()
.map(new ToVoid<>());
}
开发者ID:pitchpoint-solutions，项目名称:sfs，代码行数:19，代码来源:IndexRefresh.java
示例4: refresh
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
public RefreshResponse refresh(
final BuilderCallback<RefreshRequestBuilder> builder) {
waitForRelocation();
final RefreshResponse actionGet = builder
.apply(client().admin().indices().prepareRefresh()).execute()
.actionGet();
final ShardOperationFailedException[] shardFailures = actionGet
.getShardFailures();
if (shardFailures != null && shardFailures.length != 0) {
final StringBuilder buf = new StringBuilder(100);
for (final ShardOperationFailedException shardFailure : shardFailures) {
buf.append(shardFailure.toString()).append('\n');
}
onFailure(buf.toString(), actionGet);
}
return actionGet;
}
开发者ID:codelibs，项目名称:elasticsearch-cluster-runner，代码行数:18，代码来源:ElasticsearchClusterRunner.java
示例5: testSingleDocHttpClient
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@Test
public void testSingleDocHttpClient() throws Exception {
try (HttpClient client = HttpClient.builder()
.url(new URL("http://127.0.0.1:9200"))
.build()) {
CreateIndexRequestBuilder createIndexRequestBuilder =
new CreateIndexRequestBuilder(client, CreateIndexAction.INSTANCE).setIndex("test");
createIndexRequestBuilder.execute().actionGet();
IndexRequestBuilder indexRequestBuilder =
new IndexRequestBuilder(client, IndexAction.INSTANCE)
.setIndex("test")
.setType("type")
.setId("1")
.setSource(jsonBuilder().startObject().field("name", "Hello World").endObject());
indexRequestBuilder.execute().actionGet();
RefreshRequestBuilder refreshRequestBuilder =
new RefreshRequestBuilder(client, RefreshAction.INSTANCE)
.setIndices("test");
refreshRequestBuilder.execute().actionGet();
SearchRequestBuilder searchRequestBuilder = new SearchRequestBuilder(client, SearchAction.INSTANCE)
.setIndices("test")
.setQuery(QueryBuilders.matchAllQuery()).setSize(0);
assertTrue(searchRequestBuilder.execute().actionGet().getHits().getTotalHits() > 0);
} catch (NoNodeAvailableException e) {
logger.warn("skipping, no node available");
}
}
开发者ID:jprante，项目名称:elasticsearch-client-http，代码行数:28，代码来源:HttpBulkClientTest.java
示例6: refresh
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
private static boolean refresh(String index) {
try {
AdminClient adminClient = client.getClient().admin();
RefreshRequestBuilder refreshRequestBuilder = adminClient.indices().prepareRefresh(index);
adminClient.indices().refresh(refreshRequestBuilder.request()).actionGet();
return true;
} catch (IndexMissingException t) {
// Ignore, as means that no traces have
// been stored yet
if (msgLog.isTraceEnabled()) {
msgLog.tracef("Index [%s] not found, unable to proceed.", index);
}
return false;
}
}
开发者ID:hawkular，项目名称:hawkular-apm，代码行数:16，代码来源:AnalyticsServiceElasticsearch.java
示例7: testScroll
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@Test
public void testScroll () throws InterruptedException {
final int numOfDocs = 11;
Map<String, Integer> validIds = new HashMap <String, Integer> (numOfDocs);
for(Integer i=0;i<numOfDocs;i++){
IndexResponse indexResponse = client.prepareIndex (index_name, type_name, i.toString ())
.setSource (String.format ("{id:%s, data:\"abc\"}", i))
.execute ().actionGet ();
assertTrue(indexResponse.isCreated ());
validIds.put (i.toString (), i);
}
RefreshRequestBuilder refreshRequestBuilder = new RefreshRequestBuilder (client.admin ().indices ());
refreshRequestBuilder.setIndices (index_name).execute ().actionGet ();
Thread.sleep (1*1000);
TypeScroll scanner = new TypeScrollImpl (client, index_name, type_name, 2);
int totalCount=0;
for(SearchHit hit : scanner){
log.debug("**** HIT " + hit.getSourceAsString ());
log.debug("**** REMOVING " + hit.getId ());
validIds.remove (hit.getId ().toString ());
totalCount++;
}
assertEquals (numOfDocs, totalCount);
assertTrue(validIds.isEmpty ());
}
开发者ID:dfci-cccb，项目名称:mev，代码行数:28，代码来源:TestIndexTypeScaner.java
示例8: prepareRefresh
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@Override
public RefreshRequestBuilder prepareRefresh(String... indices) {
return new RefreshRequestBuilder(this, RefreshAction.INSTANCE).setIndices(indices);
}
开发者ID:justor，项目名称:elasticsearch_my，代码行数:5，代码来源:AbstractClient.java
示例9: refreshBuilder
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
private static RefreshRequestBuilder refreshBuilder(String... indices) {
return client().admin().indices().prepareRefresh(indices);
}
开发者ID:justor，项目名称:elasticsearch_my，代码行数:4，代码来源:IndicesOptionsIntegrationIT.java
示例10: prepareRefresh
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
default RefreshRequestBuilder prepareRefresh() {
return getClient().admin().indices().prepareRefresh(getName());
}
开发者ID:thunken，项目名称:sandow，代码行数:4，代码来源:Index.java
示例11: initTenant
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public void initTenant(String tenantId) throws StoreException {
String index = getIndex(tenantId);
if (!knownIndices.contains(index)) {
synchronized (knownIndices) {
if (!knownIndices.contains(index)) {
if (log.isLoggable(Level.FINE)) {
log.fine("Initialise mappings for tenantId = " + tenantId);
}
InputStream s = Thread.currentThread().getContextClassLoader()
.getResourceAsStream(HAWKULAR_APM_MAPPING_JSON);
if (s == null) {
s = ElasticsearchClient.class.getResourceAsStream("/" + HAWKULAR_APM_MAPPING_JSON);
}
if (s != null) {
try {
String jsonDefaultUserIndex = IOUtils.toString(s);
if (log.isLoggable(Level.FINEST)) {
log.finest("Mapping [" + jsonDefaultUserIndex + "]");
}
Map<String, Object> dataMap = XContentFactory.xContent(jsonDefaultUserIndex)
.createParser(jsonDefaultUserIndex).mapAndClose();
if (createIndex(index, (Map<String, Object>) dataMap.get(SETTINGS))) {
if (log.isLoggable(Level.FINEST)) {
log.finest("Index '" + index + "' created");
}
// refresh index
RefreshRequestBuilder refreshRequestBuilder = getClient().admin().indices()
.prepareRefresh(index);
getClient().admin().indices().refresh(refreshRequestBuilder.request())
.actionGet();
} else if (log.isLoggable(Level.FINEST)) {
log.finest("Index '" + index + "' already exists. Doing nothing.");
}
// Apply mapping in case changes have occurred - however will only be done
// once per server session, for a particular index (i.e. tenant)
prepareMapping(index, (Map<String, Object>) dataMap.get(MAPPINGS));
knownIndices.add(index);
} catch (IOException ioe) {
throw new StoreException(ioe);
}
} else {
log.warning("Could not locate '" + HAWKULAR_APM_MAPPING_JSON
+ "' index mapping file. Mapping file required to use elasticsearch");
}
}
}
}
}
开发者ID:hawkular，项目名称:hawkular-apm，代码行数:57，代码来源:ElasticsearchClient.java
示例12: getCollector
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@Override
public CollectorConfiguration getCollector(String tenantId, String type, String host, String server) {
CollectorConfiguration config = ConfigurationLoader.getConfiguration(type);
try {
String index = client.getIndex(tenantId);
RefreshRequestBuilder refreshRequestBuilder =
client.getClient().admin().indices().prepareRefresh(index);
client.getClient().admin().indices().refresh(refreshRequestBuilder.request()).actionGet();
// Only retrieve valid configurations
SearchResponse response = client.getClient().prepareSearch(index)
.setTypes(TXN_CONFIG_TYPE)
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setTimeout(TimeValue.timeValueMillis(timeout))
.setSize(maxResponseSize)
.setQuery(QueryBuilders.matchAllQuery()).execute().actionGet();
if (response.isTimedOut()) {
msgLog.warnQueryTimedOut();
}
for (SearchHit searchHitFields : response.getHits()) {
try {
TransactionConfig btc = mapper.readValue(searchHitFields.getSourceAsString(),
TransactionConfig.class);
if (!btc.isDeleted()) {
config.getTransactions().put(searchHitFields.getId(), btc);
}
} catch (Exception e) {
msgLog.errorFailedToParse(e);
}
}
} catch (org.elasticsearch.indices.IndexMissingException t) {
// Ignore, as means that no transaction configurations have
// been stored yet
if (msgLog.isTraceEnabled()) {
msgLog.tracef("No index found, so unable to retrieve transaction configs");
}
}
return config;
}
开发者ID:hawkular，项目名称:hawkular-apm，代码行数:44，代码来源:ConfigurationServiceElasticsearch.java
示例13: getTransaction
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@Override
public TransactionConfig getTransaction(String tenantId, String name) {
TransactionConfig ret = null;
if (msgLog.isTraceEnabled()) {
msgLog.tracef("Get transaction config with name[%s]", name);
}
try {
String index = client.getIndex(tenantId);
RefreshRequestBuilder refreshRequestBuilder =
client.getClient().admin().indices().prepareRefresh(index);
client.getClient().admin().indices().refresh(refreshRequestBuilder.request()).actionGet();
// First check if an invalid config exists
GetResponse response = client.getClient().prepareGet(
index, TXN_CONFIG_INVALID_TYPE, name).setRouting(name)
.execute()
.actionGet();
if (response.isSourceEmpty()) {
// Retrieve the valid configuration
response = client.getClient().prepareGet(
index, TXN_CONFIG_TYPE, name).setRouting(name)
.execute()
.actionGet();
}
if (!response.isSourceEmpty()) {
try {
ret = mapper.readValue(response.getSourceAsString(), TransactionConfig.class);
// Check if config was deleted
if (ret.isDeleted()) {
ret = null;
}
} catch (Exception e) {
msgLog.errorFailedToParse(e);
}
}
} catch (org.elasticsearch.indices.IndexMissingException t) {
// Ignore, as means that no transaction configurations have
// been stored yet
if (msgLog.isTraceEnabled()) {
msgLog.tracef("No index found, so unable to retrieve transaction config [%s]", name);
}
}
if (msgLog.isTraceEnabled()) {
msgLog.tracef("Get transaction config with name[%s] is: %s", name, ret);
}
return ret;
}
开发者ID:hawkular，项目名称:hawkular-apm，代码行数:57，代码来源:ConfigurationServiceElasticsearch.java
示例14: getTransactions
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
@Override
public Map<String, TransactionConfig> getTransactions(String tenantId, long updated) {
Map<String, TransactionConfig> ret = new HashMap<String, TransactionConfig>();
String index = client.getIndex(tenantId);
try {
RefreshRequestBuilder refreshRequestBuilder =
client.getClient().admin().indices().prepareRefresh(index);
client.getClient().admin().indices().refresh(refreshRequestBuilder.request()).actionGet();
// Should only obtain valid transactions
SearchResponse response = client.getClient().prepareSearch(index)
.setTypes(TXN_CONFIG_TYPE)
.setSearchType(SearchType.DFS_QUERY_THEN_FETCH)
.setTimeout(TimeValue.timeValueMillis(timeout))
.setSize(maxResponseSize)
.setQuery(QueryBuilders.matchAllQuery()).execute().actionGet();
if (response.isTimedOut()) {
msgLog.warnQueryTimedOut();
}
for (SearchHit searchHitFields : response.getHits()) {
try {
TransactionConfig btxn = mapper.readValue(searchHitFields.getSourceAsString(),
TransactionConfig.class);
if ((updated == 0 && !btxn.isDeleted()) || (updated > 0 && btxn.getLastUpdated() > updated)) {
ret.put(searchHitFields.getId(), btxn);
}
} catch (Exception e) {
msgLog.errorFailedToParse(e);
}
}
} catch (org.elasticsearch.indices.IndexMissingException t) {
// Ignore, as means that no transaction configurations have
// been stored yet
if (msgLog.isTraceEnabled()) {
msgLog.tracef("No index found, so unable to retrieve transaction names");
}
}
return ret;
}
开发者ID:hawkular，项目名称:hawkular-apm，代码行数:43，代码来源:ConfigurationServiceElasticsearch.java
示例15: prepareRefresh
import org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder; //导入依赖的package包/类
/**
* Explicitly refresh one or more indices (making the content indexed since the last refresh searchable).
*/
RefreshRequestBuilder prepareRefresh(String... indices);
开发者ID:justor，项目名称:elasticsearch_my，代码行数:5，代码来源:IndicesAdminClient.java
注：本文中的org.elasticsearch.action.admin.indices.refresh.RefreshRequestBuilder类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论