-
Notifications
You must be signed in to change notification settings - Fork 91
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
zhonghua
committed
Jan 19, 2020
1 parent
a890349
commit f773bdb
Showing
395 changed files
with
1,473,607 additions
and
2,969 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,11 +1,44 @@ | ||
# Created by .ignore support plugin (hsz.mobi) | ||
.idea | ||
metastore_db | ||
mr2es.iml | ||
target | ||
derby.log | ||
.DS_Store | ||
*/.DS_Store | ||
bin/ | ||
#.gitignore for java | ||
*.class | ||
|
||
# Package Files # | ||
*.jar | ||
*.war | ||
*.ear | ||
**/target/ | ||
**/output/ | ||
**/META-INF/ | ||
# logs | ||
/stacktrace.log | ||
/test/reports | ||
/logs | ||
*.log | ||
*.log.* | ||
|
||
## .gitignore for intellij | ||
*.iml | ||
*.ipr | ||
*.iws | ||
.idea/ | ||
|
||
## .gitignore for eclipse | ||
*.pydevproject | ||
.project | ||
.settings | ||
.metadata | ||
bin/** | ||
tmp/** | ||
tmp/**/* | ||
*.tmp | ||
*.bak | ||
*.swp | ||
*~.nib | ||
local.properties | ||
.classpath | ||
.settings/ | ||
.loadpath | ||
|
||
/*.settings | ||
polaris-agent/*.project | ||
polaris-agent/polaris-agent-api/*.classpath | ||
polaris-agent/polaris-agent-api/*.project | ||
.DS_Store |
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,35 +1 @@ | ||
# Introduction | ||
# <img src="imgs/logo.png" width="250px" align="center" alt="ES-Fastloader"/> | ||
The ES-Fastloader uses the fault tolerance and parallelism of Hadoop and builds individual ElasticSearch shards in multiple reducer nodes, then transfers shards to ElasticSearch cluster for serving. The loader will create a Hadoop job to read data from data files in HDFS, repartitions it on a per-node basis, and finally writes the generated indices to ES shards. In DiDi we have been using ES-Fastloader to create large-scale ElasticSearch indices from TB/PB level sequence files in Hive. | ||
|
||
# Features | ||
* Supports batch construction of ES indexes, which can quickly process dozens of terabytes of data in 1-2 hours, and solve the low-efficiency problem when building massive ES index files. | ||
* Support the horizontal expansion of computing power, and facilitate the expansion. By increasing the machine resources, you can further increase the index construction speed and the amount of data processed. | ||
|
||
# Requirements | ||
* JDK: 8 or greater | ||
* ElasticSearch: 2.3.X or greater | ||
|
||
# Deployment | ||
## Configure | ||
Edit client.properties | ||
## Build | ||
mvn clean package -Dmaven.test.skip=true -Ppro | ||
## Launch --run in hadoop cluster | ||
sh mr2es.sh project-name, e.g., sh mr2es.sh bigpassenger | ||
## Load data | ||
Refer to [here](src/main/java/com/didi/bigdata/mr2es/esCode) | ||
|
||
# Developer guide | ||
* API document [wiki](https://github.com/didi/ES-Fastloader/wiki) | ||
* Read [core library source code](https://github.com/didi/ES-Fastloader/tree/master) | ||
* Read [Release notes](RELEASE-NOTES.md) | ||
|
||
# Contributing | ||
Welcome to contribute by creating issues or sending pull requests. See [Contributing Guide](CONTRIBUTING.md) for guidelines. | ||
|
||
# Who is using ES-Fastloader? | ||
<img src="imgs/didi.png" width="78px" align="center" alt="滴滴出行"/> | ||
|
||
# License | ||
ES-Fastloader is licensed under the Apache License 2.0. See the [LICENSE](LICENSE) file. | ||
Fast Index for es by didi |
This file was deleted.
Oops, something went wrong.
This file was deleted.
Oops, something went wrong.
This file was deleted.
Oops, something went wrong.
Binary file not shown.
Binary file not shown.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,44 @@ | ||
#.gitignore for java | ||
*.class | ||
|
||
# Package Files # | ||
*.jar | ||
*.war | ||
*.ear | ||
**/target/ | ||
**/output/ | ||
**/META-INF/ | ||
# logs | ||
/stacktrace.log | ||
/test/reports | ||
/logs | ||
*.log | ||
*.log.* | ||
|
||
## .gitignore for intellij | ||
*.iml | ||
*.ipr | ||
*.iws | ||
.idea/ | ||
|
||
## .gitignore for eclipse | ||
*.pydevproject | ||
.project | ||
.metadata | ||
bin/** | ||
tmp/** | ||
tmp/**/* | ||
*.tmp | ||
*.bak | ||
*.swp | ||
*~.nib | ||
local.properties | ||
.classpath | ||
.settings/ | ||
.loadpath | ||
|
||
/*.settings | ||
polaris-agent/*.project | ||
polaris-agent/polaris-agent-api/*.classpath | ||
polaris-agent/polaris-agent-api/*.project | ||
.DS_Store |
Oops, something went wrong.