...
|
...
|
@@ -330,8 +330,8 @@ class SyncToEsCmd { |
|
|
public function toDataEs(bool $nowSubmit){
|
|
|
// 不立即提交
|
|
|
if (!$nowSubmit){
|
|
|
if($this->bulkData->total() < 10){
|
|
|
// 不足10条时 满足2秒也提交
|
|
|
if($this->bulkData->total() < 20){
|
|
|
// 不足20条时 满足2秒也提交
|
|
|
if ($this->pervSubmitTime + 2 > time()){
|
|
|
return true;
|
|
|
}
|
...
|
...
|
|