Behavior in a consistent region

The operator can participate in a consistent region. The operator can be part of a consistent region, but cannot be at the start of a consistent region.

Consistent region supports that tuples are processed at least once.

Failures during tuple processing or drain are handled by the operator and consistent region support.

On drain, the operator flushes its internal buffer and loads the documents to the Elasticsearch database.

Restrictions

The bulk size can not be configured when running in a consistent region. The parameter bulkSize is ignored and the bulk is submitted on drain.