final Class<? extends RESULT> entityType) {
        delegateBulkRequest(cb, searchHits -> {
            searchHits.forEach(hit -> {
                if (handler.isBreakCursor()) {
                    return;
                }
                final Map<String, Object> source = hit.getSourceAsMap();
                final RESULT entity = createEntity(source, entityType);

            final Class<? extends RESULT> entityType) {
        delegateBulkRequest(cb, searchHits -> {
            searchHits.forEach(hit -> {
                if (handler.isBreakCursor()) {
                    return;
                }
                final Map<String, Object> source = hit.getSourceAsMap();
                final RESULT entity = createEntity(source, entityType);

            final Class<? extends RESULT> entityType) {
        delegateBulkRequest(cb, searchHits -> {
            searchHits.forEach(hit -> {
                if (handler.isBreakCursor()) {
                    return;
                }
                final Map<String, Object> source = hit.getSourceAsMap();
                final RESULT entity = createEntity(source, entityType);

        }
    }

    private static abstract class LogEntityRowHandler<ENTITY> implements EntityRowHandler<ENTITY> {
        protected boolean breakCursor = false;

        @Override
        public boolean isBreakCursor() {
            return breakCursor;
        }
    }