elasticsearch5.0如何创建client

Elasticsearchyemaohai2016 回复了问题 • 2 人关注 • 2 个回复 • 4917 次浏览 • 2016-11-10 14:29 • 来自相关话题

使用suggest建议器,返回了所有数据

回复

Elasticsearchmafa1993 发起了问题 • 1 人关注 • 0 个回复 • 1998 次浏览 • 2016-11-10 14:17 • 来自相关话题

书上提到了一个切面,然后说后期可能会废弃,废弃没

ElasticsearchXargin 回复了问题 • 3 人关注 • 2 个回复 • 2876 次浏览 • 2016-11-10 11:16 • 来自相关话题

请问如何按每天的时间段统计条目数量

ElasticsearchyvesYang 回复了问题 • 4 人关注 • 4 个回复 • 4648 次浏览 • 2016-11-10 09:49 • 来自相关话题

ES2.2.0设置bulk线程池无效

Elasticsearchwx7614140 回复了问题 • 2 人关注 • 2 个回复 • 2614 次浏览 • 2016-11-09 18:26 • 来自相关话题

ELK 不同行之间取值计算问题

回复

Elasticsearchleoruan 发起了问题 • 1 人关注 • 0 个回复 • 2687 次浏览 • 2016-11-08 22:14 • 来自相关话题

关联搜索要求同索引,如果关联数据过多,会不会导致分片为1

回复

Elasticsearchlbeny 回复了问题 • 1 人关注 • 1 个回复 • 2113 次浏览 • 2016-11-08 21:20 • 来自相关话题

如何重建索引,名称与之前索引名称一样

Elasticsearchnb114917778 回复了问题 • 2 人关注 • 1 个回复 • 2887 次浏览 • 2016-11-08 19:28 • 来自相关话题

completion suggest

回复

Elasticsearchjakemanse 发起了问题 • 1 人关注 • 0 个回复 • 2283 次浏览 • 2016-11-08 18:58 • 来自相关话题

Pandasticsearch: An Elasticsearch client exposing DataFrame API

Elasticsearchonesuper 发表了文章 • 0 个评论 • 2247 次浏览 • 2016-11-08 18:02 • 来自相关话题

https://github.com/onesuper/pandasticsearch
 
# Create a DataFrame object
from pandasticsearch import DataFrame
df = DataFrame.from_es('http://localhost:9200', index='people')

# Print the schema(mapping) of the index
df.print_schema()
# company
# |-- employee
# |-- name: {'index': 'not_analyzed', 'type': 'string'}
# |-- age: {'type': 'integer'}
# |-- gender: {'index': 'not_analyzed', 'type': 'string'}

# Inspect the columns
df.columns
#['name', 'age', 'gender']

# Get the column
df.name
# Column('name')

# Filter
df.filter(df.age < 13).collect()
# [Row(age=12,gender='female',name='Alice'), Row(age=11,gender='male',name='Bob')]

# Project
df.filter(df.age < 25).select('name', 'age').collect()
# [Row(age=12,name='Alice'), Row(age=11,name='Bob'), Row(age=13,name='Leo')]

# Print the rows into console
df.filter(df.age < 25).select('name').show(3)
# +------+
# | name |
# +------+
# | Alice|
# | Bob |
# | Leo |
# +------+

# Sort
df.sort(df.age.asc).select('name', 'age').collect()
#[Row(age=11,name='Bob'), Row(age=12,name='Alice'), Row(age=13,name='Leo')]

# Aggregate
df[df.gender == 'male'].agg(df.age.avg).collect()
# [Row(avg(age)=12)]

# Groupby
df.groupby('gender').collect()
# [Row(doc_count=1), Row(doc_count=2)]

# Groupby and then aggregate
df.groupby('gender').agg(df.age.max).collect()
# [Row(doc_count=1, max(age)=12), Row(doc_count=2, max(age)=13)]

# Convert to Pandas object for subsequent analysis
df[df.gender == 'male'].agg(df.age.avg).to_pandas()
# avg(age)
# 0 12

Kafka+Logstash的问题

回复

Logstashdennishood 回复了问题 • 2 人关注 • 1 个回复 • 4662 次浏览 • 2016-11-08 10:52 • 来自相关话题

es 怎么去除掉 结果 _score<1的?

Elasticsearchstrglee 回复了问题 • 2 人关注 • 2 个回复 • 2705 次浏览 • 2016-11-07 21:17 • 来自相关话题

mysql中查询语句如何翻译成ES查询语句

ElasticsearchXargin 回复了问题 • 2 人关注 • 1 个回复 • 6789 次浏览 • 2016-11-07 16:20 • 来自相关话题

org.elasticsearch.client 5.0在idea 和gradle中无法跟新

回复

Elasticsearchqijun4tian 发起了问题 • 1 人关注 • 0 个回复 • 3019 次浏览 • 2016-11-07 16:18 • 来自相关话题

siren-join java api出错

回复

Elasticsearchlbeny 发起了问题 • 1 人关注 • 0 个回复 • 2766 次浏览 • 2016-11-07 11:41 • 来自相关话题