|
@ -174,7 +174,7 @@ public class MysqlToEsQuotaJob implements Job {
|
|
|
new BoolQueryBuilder()
|
|
|
.must(QueryBuilders.matchQuery("quotaCode", quotaCode))
|
|
|
.must(QueryBuilders.matchQuery("timeLevel", timeLevel))
|
|
|
.must(QueryBuilders.matchQuery("quotaDate", quotaDate))).size(10000);
|
|
|
.must(QueryBuilders.matchQuery("quotaDate", quotaDate))).size(10000);//一次取10000条
|
|
|
|
|
|
Search search = new Search.Builder(searchSourceBuilder.toString()).addIndex(esIndex).addType(esType)
|
|
|
.build();
|