本文整理了Java中org.elasticsearch.client.transport.TransportClient.prepareDeleteByQuery()
方法的一些代码示例,展示了TransportClient.prepareDeleteByQuery()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。TransportClient.prepareDeleteByQuery()
方法的具体详情如下:
包路径:org.elasticsearch.client.transport.TransportClient
类名称:TransportClient
方法名:prepareDeleteByQuery
暂无
代码示例来源:origin: com.impetus.client/kundera-elastic-search
@Override
public void deleteByColumn(String schemaName, String tableName, String columnName, Object columnValue)
{
Map<String,Object> querySource = new HashMap<String, Object>();
querySource.put(columnName, columnValue);
DeleteByQueryRequestBuilder deleteQueryBuilder = txClient.prepareDeleteByQuery(schemaName.toLowerCase()).setQuery(querySource).setTypes(tableName);
deleteQueryBuilder.execute().actionGet();
}
代码示例来源:origin: lumifyio/securegraph
private void deleteChildDocuments(String indexName, Element element) {
String parentId = element.getId();
DeleteByQueryResponse response = getClient()
.prepareDeleteByQuery(indexName)
.setTypes(PROPERTY_TYPE)
.setQuery(
QueryBuilders.termQuery("_parent", ELEMENT_TYPE + "#" + parentId)
)
.execute()
.actionGet();
if (response.status() != RestStatus.OK) {
throw new SecureGraphException("Could not remove child elements " + element.getId() + " (status: " + response.status() + ")");
}
if (LOGGER.isDebugEnabled()) {
for (IndexDeleteByQueryResponse r : response) {
LOGGER.debug("deleted child document " + r.toString());
}
}
}
代码示例来源:origin: org.neolumin.vertexium/vertexium-elasticsearch-parentchild
private void deleteChildDocuments(String indexName, Element element) {
String parentId = element.getId();
DeleteByQueryResponse response = getClient()
.prepareDeleteByQuery(indexName)
.setTypes(PROPERTY_TYPE)
.setQuery(
QueryBuilders.termQuery("_parent", ELEMENT_TYPE + "#" + parentId)
)
.execute()
.actionGet();
if (response.status() != RestStatus.OK) {
throw new VertexiumException("Could not remove child elements " + element.getId() + " (status: " + response.status() + ")");
}
if (LOGGER.isDebugEnabled()) {
for (IndexDeleteByQueryResponse r : response) {
LOGGER.debug("deleted child document " + r.toString());
}
}
}
内容来源于网络,如有侵权,请联系作者删除!