Java ElasticSearchIndexRequestBuilderFactory类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory类的典型用法代码示例。如果您正苦于以下问题：Java ElasticSearchIndexRequestBuilderFactory类的具体用法？Java ElasticSearchIndexRequestBuilderFactory怎么用？Java ElasticSearchIndexRequestBuilderFactory使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ElasticSearchIndexRequestBuilderFactory类属于org.apache.flume.sink.elasticsearch包，在下文中一共展示了ElasticSearchIndexRequestBuilderFactory类的11个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: FlumeESSinkAndTestData

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
private void FlumeESSinkAndTestData(List<Event> searchEvents)
		throws EventDeliveryException, IOException, FileNotFoundException {
	flumeESSinkService.processEvents(searchEvents);

	Client client = searchClientService.getClient();
	client.admin().indices().refresh(Requests.refreshRequest()).actionGet();

	String indexName = "recentlyviewed" + '-'
			+ ElasticSearchIndexRequestBuilderFactory.df.format(new Date());
	long totalCount = client.prepareCount(indexName).get().getCount();
	System.out.println("Search total count is: " + totalCount);

	SearchHits hits = client.prepareSearch(indexName).get().getHits();
	System.out.println("Total hits: " + hits.getTotalHits());
	for (SearchHit searchHit : hits) {
		System.out.println(searchHit.getSource());
	}
}

开发者ID:jaibeermalik，项目名称:searchanalytics-bigdata，代码行数:19，代码来源:CompleteSetupIntegrationTest.java

示例2: testProcessEvents

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
@Test
public void testProcessEvents() {
	int searchEventsCount = 101;
	List<Event> searchEvents = generateSearchAnalyticsDataService
			.getSearchEvents(searchEventsCount);

	flumeESSinkService.processEvents(searchEvents);

	Client client = searchClientService.getClient();
	client.admin().indices().refresh(Requests.refreshRequest()).actionGet();

	String indexName = "recentlyviewed" + '-'
			+ ElasticSearchIndexRequestBuilderFactory.df.format(new Date());
	long totalCount = client.prepareCount(indexName).get().getCount();
	System.out.println("Search total count is: " + totalCount);

	SearchHits hits = client.prepareSearch(indexName).get().getHits();
	System.out.println("Total hits: " + hits.getTotalHits());
	for (SearchHit searchHit : hits) {
		System.out.println(searchHit.getSource());
	}

}

开发者ID:jaibeermalik，项目名称:searchanalytics-bigdata，代码行数:24，代码来源:FlumeESSinkServiceTest.java

示例3: getClient

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
/**
 *
 * @param clientType
 *    String representation of client type
 * @param hostNames
 *    Array of strings that represents hostnames with ports (hostname:port)
 * @param clusterName
 *    Elasticsearch cluster name used only by Transport Client
 * @param serializer
 *    Serializer of flume events to elasticsearch documents
 * @return
 */
public ElasticSearchClient getClient(String clientType, String[] hostNames,
    String clusterName, ElasticSearchEventSerializer serializer,
    ElasticSearchIndexRequestBuilderFactory indexBuilder) throws NoSuchClientTypeException {
  if (clientType.equalsIgnoreCase(TransportClient) && serializer != null) {
    return new ElasticSearchTransportClient(hostNames, clusterName, serializer);
  } else if (clientType.equalsIgnoreCase(TransportClient) && indexBuilder != null) { 
    return new ElasticSearchTransportClient(hostNames, clusterName, indexBuilder);
  } else if (clientType.equalsIgnoreCase(RestClient) && serializer != null) {
    return new ElasticSearchRestClient(hostNames, serializer);
  }
  throw new NoSuchClientTypeException();
}

开发者ID:moueimei，项目名称:flume-release-1.7.0，代码行数:25，代码来源:ElasticSearchClientFactory.java

示例4: getLocalClient

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
/**
 * Used for tests only. Creates local elasticsearch instance client.
 *
 * @param clientType Name of client to use
 * @param serializer Serializer for the event
 * @param indexBuilder Index builder factory
 *
 * @return Local elastic search instance client
 */
public ElasticSearchClient getLocalClient(String clientType,
                                          ElasticSearchEventSerializer serializer,
                                          ElasticSearchIndexRequestBuilderFactory indexBuilder)
    throws NoSuchClientTypeException {
  if (clientType.equalsIgnoreCase(TransportClient) && serializer != null) {
    return new ElasticSearchTransportClient(serializer);
  } else if (clientType.equalsIgnoreCase(TransportClient) && indexBuilder != null)  {
    return new ElasticSearchTransportClient(indexBuilder);
  } else if (clientType.equalsIgnoreCase(RestClient)) {
  }
  throw new NoSuchClientTypeException();
}

开发者ID:moueimei，项目名称:flume-release-1.7.0，代码行数:22，代码来源:ElasticSearchClientFactory.java

示例5: ElasticSearchTransportClient

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
/**
 * Used for testing
 */
public ElasticSearchTransportClient(Client client,
                                    ElasticSearchIndexRequestBuilderFactory requestBuilderFactory)
    throws IOException {
  this.client = client;
  requestBuilderFactory.createIndexRequest(client, null, null, null);
}

开发者ID:moueimei，项目名称:flume-release-1.7.0，代码行数:10，代码来源:ElasticSearchTransportClient.java

示例6: getClient

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
/**
 *
 * @param clientType String representation of client type
 * @param hostNames Array of strings that represents hosntames with ports
 * (hostname:port)
 * @param clusterName Elasticsearch cluster name used only by Transport
 * Client
 * @param serializer Serializer of flume events to elasticsearch documents
 * @return
 */
public ElasticSearchClient getClient(String clientType, String[] hostNames,
        String clusterName, ElasticSearchEventSerializer serializer,
        ElasticSearchIndexRequestBuilderFactory indexBuilder) throws NoSuchClientTypeException {
    if (clientType.equalsIgnoreCase(TransportClient) && serializer != null) {
        return new ElasticSearchTransportClient(hostNames, clusterName, serializer);
    } else if (clientType.equalsIgnoreCase(TransportClient) && indexBuilder != null) {
        return new ElasticSearchTransportClient(hostNames, clusterName, indexBuilder);
    } else if (clientType.equalsIgnoreCase(RestClient) && serializer != null) {
        return new ElasticSearchRestClient(hostNames, serializer);
    }
    throw new NoSuchClientTypeException();
}

开发者ID:Redliver，项目名称:flume-ng-elasticsearch5-sink，代码行数:23，代码来源:ElasticSearchClientFactory.java

示例7: getLocalClient

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
/**
 * Used for tests only. Creates local elasticsearch instance client.
 *
 * @param clientType Name of client to use
 * @param serializer Serializer for the event
 * @param indexBuilder Index builder factory
 *
 * @return Local elastic search instance client
 */
public ElasticSearchClient getLocalClient(String clientType, ElasticSearchEventSerializer serializer,
        ElasticSearchIndexRequestBuilderFactory indexBuilder) throws NoSuchClientTypeException {
    if (clientType.equalsIgnoreCase(TransportClient) && serializer != null) {
        return new ElasticSearchTransportClient(serializer);
    } else if (clientType.equalsIgnoreCase(TransportClient) && indexBuilder != null) {
        return new ElasticSearchTransportClient(indexBuilder);
    } else if (clientType.equalsIgnoreCase(RestClient)) {
    }
    throw new NoSuchClientTypeException();
}

开发者ID:Redliver，项目名称:flume-ng-elasticsearch5-sink，代码行数:20，代码来源:ElasticSearchClientFactory.java

示例8: ElasticSearchTransportClient

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
public ElasticSearchTransportClient(String[] hostNames, String clusterName,
        ElasticSearchIndexRequestBuilderFactory indexBuilder) {
    configureHostnames(hostNames);
    this.indexRequestBuilderFactory = indexBuilder;
    openClient(clusterName);
}

开发者ID:Redliver，项目名称:flume-ng-elasticsearch5-sink，代码行数:7，代码来源:ElasticSearchTransportClient.java

示例9: initDefaults

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
void initDefaults() {
	timestampedIndexName = DEFAULT_INDEX_NAME + '-'
			+ ElasticSearchIndexRequestBuilderFactory.df.format(FIXED_TIME_MILLIS);
	dateFormat = FastDateFormat.getInstance("yyyy.MM.dd", TimeZone.getTimeZone("Etc/UTC"));
}

开发者ID:gigya，项目名称:flume-ng-elasticsearch-ser-ex，代码行数:6，代码来源:TestElasticSearchIndexRequestBuilderFactory.java

示例10: getIndexName

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
private String getIndexName(String indexPrefix, long timestamp) {
	return new StringBuilder(indexPrefix).append('-')
			.append(ElasticSearchIndexRequestBuilderFactory.df
					.format(timestamp)).toString();
}

开发者ID:Stratio，项目名称:ingestion，代码行数:6，代码来源:ElasticSearchSerializerWithMappingTest.java

示例11: getIndexName

import org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory; //导入依赖的package包/类
/**
 * Gets the name of the index to use for an index request
 * 
 * @return index name of the form 'indexPrefix-formattedTimestamp'
 * @param indexPrefix
 *            Prefix of index name to use -- as configured on the sink
 * @param timestamp
 *            timestamp (millis) to format / use
 */
private String getIndexName(String indexPrefix, long timestamp) {
	return new StringBuilder(indexPrefix)
			.append('-')
			.append(ElasticSearchIndexRequestBuilderFactory.df
					.format(timestamp)).toString();
}

开发者ID:Stratio，项目名称:ingestion，代码行数:16，代码来源:ElasticSearchSerializerWithMapping.java

注：本文中的org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。