elasticsearch jdbc river plugin 트랙이 mysql의 기존 행을 변경합니까?

Question

jdbc river plugin은 간단한 전략 모드에서 새로운 행을 추가 할 때 인덱스를 업데이트하지만 필드 값에 변경 사항이있는 경우 기존 행을 업데이트합니까? 데이터베이스에있는 타임 스탬프 필드와 매핑이 없다는 것을 알았으므로 그렇지 않습니다.

Answer 1

아래 예제와 같이 $river.state.last_active_begin을 사용하여 쿼리 내에서 타임 스탬프를 사용할 수 있습니다. 이렇게하면 마지막 강이 실행 된 이후에 추가 된 제품 행을 가져옵니다.

{ 
    "type": "jdbc", 
    "jdbc": { 
    "url": "jdbc:mysql://localhost:3306/test", 
    "user": "", 
    "password": "", 
    "sql": [ 
     { 
     "statement": "select * from \"products\" where \"mytimestamp\" > ?", 
     "parameter": [ 
      "$river.state.last_active_begin" 
     ] 
     } 
    ], 
    "index": "my_jdbc_river_index", 
    "type": "my_jdbc_river_type" 
    } 
}