Package org.codelibs.fess.es.log.allcommon

Class EsAbstractBehavior<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

java.lang.Object
org.dbflute.bhv.AbstractBehaviorReadable<ENTITY,CB>
org.dbflute.bhv.AbstractBehaviorWritable<ENTITY,CB>
org.codelibs.fess.es.log.allcommon.EsAbstractBehavior<ENTITY,CB>
Type Parameters:
ENTITY - The type of entity.
CB - The type of condition-bean.
All Implemented Interfaces:
org.dbflute.bhv.BehaviorReadable, org.dbflute.bhv.BehaviorWritable
Direct Known Subclasses:
BsClickLogBhv, BsFavoriteLogBhv, BsSearchLogBhv, BsUserInfoBhv
public abstract class EsAbstractBehavior<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean> extends org.dbflute.bhv.AbstractBehaviorWritable<ENTITY,CB>
Author:
ESFlute (using FreeGen)

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    static class 
    EsAbstractBehavior.BulkList<E,B>
     

    Nested classes/interfaces inherited from class org.dbflute.bhv.AbstractBehaviorReadable

    org.dbflute.bhv.AbstractBehaviorReadable.InternalLoadReferrerCallback<LOCAL_ENTITY extends org.dbflute.Entity,PK extends Object,REFERRER_CB extends org.dbflute.cbean.ConditionBean,REFERRER_ENTITY extends org.dbflute.Entity>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected String
    bulkTimeout
     
    protected String
    deleteTimeout
     
    protected String
    indexTimeout
     
    protected String
    refreshTimeout
     
    protected String
    scrollForCursor
     
    protected String
    scrollForDelete
     
    protected String
    scrollSearchTimeout
     
    protected String
    searchTimeout
     
    protected int
    sizeForCursor
     
    protected int
    sizeForDelete
     

    Fields inherited from class org.dbflute.bhv.AbstractBehaviorWritable

    _commonColumnAutoSetupper, EMPTY_INT_ARRAY

    Fields inherited from class org.dbflute.bhv.AbstractBehaviorReadable

    _behaviorCommandInvoker, _behaviorSelector, DERIVED_MAPPABLE_ALIAS_PREFIX, EMPTY_NREF_LGWAY

  • Constructor Summary

    Constructors
    Constructor
    Description
    EsAbstractBehavior()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected abstract String
    asEsIndex()
     
    protected abstract String
    asEsIndexType()
     
    protected abstract String
    asEsSearchType()
     
    protected org.opensearch.action.delete.DeleteRequestBuilder
    createDeleteRequest(EsAbstractEntity esEntity)
     
    protected abstract <RESULT extends ENTITY>
    RESULT
    createEntity(Map<String,Object> source, Class<? extends RESULT> entityType)
     
    protected org.opensearch.action.index.IndexRequestBuilder
    createInsertRequest(EsAbstractEntity esEntity)
     
    protected <RESULT extends org.dbflute.Entity>
    org.dbflute.cbean.result.ListResultBean<RESULT>
    createListResultBean(org.dbflute.cbean.ConditionBean cb, List<RESULT> selectedList)
     
    protected org.dbflute.bhv.writable.UpdateOption<CB>
    createPlainUpdateOption()
     
    protected org.opensearch.action.index.IndexRequestBuilder
    createUpdateRequest(EsAbstractEntity esEntity)
     
    protected int[]
    delegateBatchDelete(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
     
    protected int[]
    delegateBatchInsert(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)
     
    protected <BUILDER> int[]
    delegateBatchRequest(List<? extends org.dbflute.Entity> entityList, Function<EsAbstractEntity,BUILDER> call)
     
    protected int[]
    delegateBatchUpdate(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)
     
    protected void
    delegateBulkRequest(org.dbflute.cbean.ConditionBean cb, Function<org.opensearch.search.SearchHits,Boolean> handler)
     
    protected int
    delegateDelete(org.dbflute.Entity entity, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
     
    protected int
    delegateInsert(org.dbflute.Entity entity, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)
     
    protected int
    delegateQueryDelete(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
     
    protected <RESULT extends ENTITY>
    void
    delegateSelectBulk(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.readable.EntityRowHandler<List<RESULT>> handler, Class<? extends RESULT> entityType)
     
    protected int
    delegateSelectCountUniquely(org.dbflute.cbean.ConditionBean cb)
     
    protected <RESULT extends ENTITY>
    void
    delegateSelectCursor(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.readable.EntityRowHandler<RESULT> handler, Class<? extends RESULT> entityType)
     
    protected <RESULT extends ENTITY>
    RESULT
    delegateSelectEntity(org.dbflute.cbean.ConditionBean cb, Class<? extends RESULT> entityType)
     
    protected <RESULT extends ENTITY>
    List<RESULT>
    delegateSelectList(org.dbflute.cbean.ConditionBean cb, Class<? extends RESULT> entityType)
     
    protected int
    delegateUpdate(org.dbflute.Entity entity, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)
     
    protected void
    deleteScrollContext(String scrollId)
     
    protected Number
    doReadNextVal()
     
    protected org.opensearch.search.SearchHits
    getSearchHits(org.opensearch.action.search.SearchResponse response)
     
    protected <RESULT extends ENTITY>
    void
    helpSelectCursorHandlingByPaging(CB cb, org.dbflute.bhv.readable.EntityRowHandler<RESULT> handler, Class<? extends RESULT> entityType, org.dbflute.cbean.coption.CursorSelectOption option)
     
    protected boolean
    isCompatibleBatchInsertDefaultEveryColumn()
     
    org.opensearch.action.admin.indices.refresh.RefreshResponse
    refresh()
     
    void
    setBulkTimeout(String bulkTimeout)
     
    void
    setDeleteTimeout(String deleteTimeout)
     
    void
    setIndexTimeout(String indexTimeout)
     
    void
    setRefreshTimeout(String refreshTimeout)
     
    void
    setScrollForCursor(String scrollForCursor)
     
    void
    setScrollForDelete(String scrollForDelete)
     
    void
    setScrollSearchTimeout(String scrollSearchTimeout)
     
    void
    setSearchTimeout(String searchTimeout)
     
    void
    setSizeForCursor(int sizeForCursor)
     
    void
    setSizeForDelete(int sizeForDelete)
     
    protected Date
    toDate(Object value)
     
    protected LocalDateTime
    toLocalDateTime(Object value)
     
    protected Map<String,Object>
    toSource(EsAbstractEntity esEntity)
     
    protected String[]
    toStringArray(Object value)
     

    Methods inherited from class org.dbflute.bhv.AbstractBehaviorWritable

    adjustEntityBeforeDelete, adjustEntityBeforeInsert, adjustEntityBeforeQueryDelete, adjustEntityBeforeQueryInsert, adjustEntityBeforeQueryUpdate, adjustEntityBeforeUpdate, adjustEntityListBeforeBatchDelete, adjustEntityListBeforeBatchInsert, adjustEntityListBeforeBatchUpdate, assertDeleteOpCallNotNull, assertDeleteOptionStatus, assertEntityHasOptimisticLockValue, assertEntityHasUpdateDateValue, assertEntityHasVersionNoValue, assertEntityOfDelete, assertEntityOfInsert, assertEntityOfUpdate, assertInsertOpCallNotNull, assertInsertOptionStatus, assertQueryDeleteStatus, assertQueryUpdateStatus, assertUpdateColumnSpecificationNotNull, assertUpdateOpCallNotNull, assertUpdateOptionStatus, checkCountBeforeQueryUpdateIfNeeds, create, createBatchDeleteCommand, createBatchDeleteNonstrictCommand, createBatchInsertCommand, createBatchUpdateCommand, createBatchUpdateNonstrictCommand, createCBForQueryInsert, createCBForSpecifiedUpdate, createCBForVaryingUpdate, createDeleteEntityCommand, createDeleteNonstrictEntityCommand, createDeleteOption, createInsertOption, createOptionalCause, createOptionalDeleteOption, createOptionalUpdateOption, createOrModify, createOrModifyNonstrict, createPlainInsertOption, createQueryDeleteCBCommand, createQueryInsertCBCommand, createQueryUpdateCBCommand, createSpecifiedUpdateOption, createUpdateEntityCommand, createUpdateNonstrictEntityCommand, createUpdateOption, delegateBatchDeleteNonstrict, delegateBatchUpdateNonstrict, delegateDeleteNonstrict, delegateQueryInsert, delegateQueryUpdate, delegateUpdateNonstrict, doBatchDelete, doBatchDeleteNonstrict, doBatchInsert, doBatchUpdate, doBatchUpdateNonstrict, doCreate, doCreateOrModify, doCreateOrModifyNonstrict, doDelete, doDeleteNonstrict, doInsert, doInsertOrUpdate, doInsertOrUpdateNonstrict, doLumpCreate, doLumpModify, doLumpModifyNonstrict, doLumpRemove, doLumpRemoveNonstrict, doModify, doModifyNonstrict, doQueryDelete, doQueryInsert, doQueryUpdate, doRangeCreate, doRangeModify, doRangeRemove, doRemove, doRemoveNonstrict, doUpdate, doUpdateNonstrict, downcast, downcast, downcast, downcast, emptyOpt, filterEntityOfDelete, filterEntityOfInsert, filterEntityOfUpdate, frameworkFilterEntityOfDelete, frameworkFilterEntityOfInsert, frameworkFilterEntityOfUpdate, getCommonColumnAutoSetupper, helpDeleteInternally, helpDeleteNonstrictIgnoreDeletedInternally, helpDeleteNonstrictInternally, helpDetermineInsertOrUpdateDirectInsert, helpInsertOrUpdateInternally, helpInsertOrUpdateNonstrictInternally, helpReloadPrimaryKeyIfUniqueByIfNeeds, helpUpdateInternally, helpUpdateNonstrictInternally, hookBeforeDelete, hookBeforeInsert, hookBeforeUpdate, hookFinallyDelete, hookFinallyInsert, hookFinallyUpdate, injectSequenceToPrimaryKeyIfNeeds, isBatchInsertColumnModifiedPropertiesFragmentedDisallowed, isBatchUpdateColumnModifiedPropertiesFragmentedAllowed, isCompatibleBatchUpdateDefaultEveryColumn, lumpCreate, lumpModify, lumpModifyNonstrict, lumpRemove, lumpRemoveNonstrict, modify, modifyNonstrict, newBatchDeleteCommand, newBatchDeleteNonstrictCommand, newBatchInsertCommand, newBatchUpdateCommand, newBatchUpdateNonstrictCommand, newDeleteEntityCommand, newDeleteNonstrictEntityCommand, newDeleteOption, newInsertOption, newUpdateEntityCommand, newUpdateNonstrictEntityCommand, newUpdateOption, prepareBatchInsertOption, prepareBatchUpdateOption, prepareDeleteOption, prepareEntityDelete, prepareEntityDeleteOption, prepareEntityUpdate, prepareEntityUpdateOption, prepareInsertOption, prepareUpdateOption, rangeCreate, rangeModify, rangeRemove, reflectUniqueDriven, remove, removeNonstrict, setCommonColumnAutoSetupper, setupCommonColumnOfInsertIfNeeds, setupCommonColumnOfUpdateIfNeeds, setupExclusiveControlColumnOfQueryInsert, setupListEntityCommand, throwUpdateDateValueNullException, throwUpdateEntityAlreadyDeletedException, throwUpdateEntityDuplicatedException, throwVersionNoValueNullException

    Methods inherited from class org.dbflute.bhv.AbstractBehaviorReadable

    assertBehaviorCommandInvoker, assertCBCallNotNull, assertCBNotDreamCruise, assertCBNotNull, assertCBStateValid, assertConditionBeanSelectResource, assertEntityListNotNull, assertEntityNotDeleted, assertEntityNotNull, assertEntityNotNullAndHasPrimaryKeyValue, assertListNotNullAndEmpty, assertListNotNullAndHasOnlyOne, assertListNotNullAndNotEmpty, assertObjectNotNull, assertSpecifyDerivedReferrerEntityProperty, assertStringNotNullAndNotTrimmedEmpty, createBhvExThrower, createCB, createCBExThrower, createExceptionMessageBuilder, createHpSLSExecutor, createInsertEntityCommand, createOptionalEntity, createOptionalInsertOption, createPagingHandler, createPagingInvoker, createSelectCountCBCommand, createSelectCursorCBCommand, createSelectEntityCBCommand, createSelectListCBCommand, createSelectNextValCommand, createSelectNextValSubCommand, createSelectScalarCBCommand, createSLSFunction, delegateInsertNoPK, delegateSelectCountPlainly, delegateSelectNextVal, delegateSelectNextValSub, doHelpLoadReferrerInternally, doHelpLoadReferrerInternally, doOutsideSql, doReadCount, doReadEntity, doReadEntityWithDeletedCheck, doReadList, doReadPage, doReadScalar, doScalarSelect, doSelectCountPlainly, doSelectCountUniquely, doSelectCursor, doSelectEntity, doSelectEntityWithDeletedCheck, doSelectList, doSelectPage, downcast, downcast, downcast, facadeScalarSelect, facadeSelectCount, facadeSelectCursor, facadeSelectEntityWithDeletedCheck, facadeSelectList, facadeSelectPage, getBehaviorCommandInvoker, getBehaviorSelector, hasUpdateDateValue, hasVersionNoValue, helpConditionBeanDowncastInternally, helpEntityDowncastInternally, helpExtractListInternally, helpExtractSetInternally, helpLoadReferrerInternally, helpLoadReferrerInternally, helpPulloutInternally, helpSelectCursorCheckingByPagingAllowed, helpSelectCursorCheckingOrderByPK, helpSelectCursorInternally, helpSelectEntityInternally, helpSelectEntityWithDeletedCheckInternally, helpSelectListInternally, helpSelectPageInternally, invoke, isEntityDerivedMappable, isRelationOptional, ln, newConditionBean, newEntity, newInsertEntityCommand, newSelectCountCBCommand, newSelectCursorCBCommand, newSelectEntityCBCommand, newSelectListCBCommand, newSelectNextValCommand, newSelectNextValSubCommand, newSelectScalarCBCommand, newSLSFunction, readCount, readCursor, readEntity, readEntityWithDeletedCheck, readList, readNextVal, readPage, readScalar, readyOutsideSql, setBehaviorCommandInvoker, setBehaviorSelector, throwSelectEntityAlreadyDeletedException, throwSelectEntityConditionNotFoundException, throwSelectEntityDuplicatedException, throwSpecifyDerivedReferrerEntityPropertyNotFoundException, toLoadReferrerMappingKey, toLowerCaseIfString, toRelationOptional, typeOfHandlingConditionBean, typeOfHandlingEntity, typeOfSelectedEntity, warmUpCommand, xassLRArg, xassLRArg, xassLRArg, xassLRArg, xassLRArg, xassLRArg, xbuildReferrerCorrelatedFixedCondition, xcheckSafetyResultAsOne, xconvertFK2PKImplicitly, xconvertToRelationOptionalEntityIfNeeds, xcreateLoadReferrerCallback, xcreateLoadReferrerCallback, xdoBuildReferrerCorrelatedFixedCondition, xdoHelpExtractSetInternally, xextractPulloutForeignEntity, xextractPulloutReverseWrittenObject, xfindReferrerBehavior, xgetBSFLR, xgetROpFactory, xnewLoadReferrerCompoundKeyMap, xnewLRAryLs, xnewLRLs, xpreparePulloutResultList, xrestoreSafetyResult, xsavePulloutForeignEntity, xsetupEntityCommand, xsetupSelectCommand

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.dbflute.bhv.BehaviorReadable

    asDBMeta, asTableDbName, newConditionBean, newEntity, readCount, readCursor, readEntity, readEntityWithDeletedCheck, readList, readNextVal, readPage, readScalar, readyOutsideSql, warmUpCommand

  • Field Details

    • sizeForDelete

      protected int sizeForDelete

    • scrollForDelete

      protected String scrollForDelete

    • sizeForCursor

      protected int sizeForCursor

    • scrollForCursor

      protected String scrollForCursor

    • searchTimeout

      protected String searchTimeout

    • indexTimeout

      protected String indexTimeout

    • scrollSearchTimeout

      protected String scrollSearchTimeout

    • bulkTimeout

      protected String bulkTimeout

    • deleteTimeout

      protected String deleteTimeout

    • refreshTimeout

      protected String refreshTimeout

  • Constructor Details

    • EsAbstractBehavior

      public EsAbstractBehavior()

  • Method Details

    • asEsIndex

      protected abstract String asEsIndex()

    • asEsIndexType

      protected abstract String asEsIndexType()

    • asEsSearchType

      protected abstract String asEsSearchType()

    • createEntity

      protected abstract <RESULT extends ENTITY> RESULT createEntity(Map<String,Object> source, Class<? extends RESULT> entityType)

    • refresh

      public org.opensearch.action.admin.indices.refresh.RefreshResponse refresh()

    • delegateSelectCountUniquely

      protected int delegateSelectCountUniquely(org.dbflute.cbean.ConditionBean cb)
      Overrides:
      delegateSelectCountUniquely in class org.dbflute.bhv.AbstractBehaviorReadable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • delegateSelectEntity

      protected <RESULT extends ENTITY> RESULT delegateSelectEntity(org.dbflute.cbean.ConditionBean cb, Class<? extends RESULT> entityType)
      Overrides:
      delegateSelectEntity in class org.dbflute.bhv.AbstractBehaviorReadable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • delegateSelectList

      protected <RESULT extends ENTITY> List<RESULT> delegateSelectList(org.dbflute.cbean.ConditionBean cb, Class<? extends RESULT> entityType)
      Overrides:
      delegateSelectList in class org.dbflute.bhv.AbstractBehaviorReadable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • helpSelectCursorHandlingByPaging

      protected <RESULT extends ENTITY> void helpSelectCursorHandlingByPaging(CB cb, org.dbflute.bhv.readable.EntityRowHandler<RESULT> handler, Class<? extends RESULT> entityType, org.dbflute.cbean.coption.CursorSelectOption option)
      Overrides:
      helpSelectCursorHandlingByPaging in class org.dbflute.bhv.AbstractBehaviorReadable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • delegateSelectCursor

      protected <RESULT extends ENTITY> void delegateSelectCursor(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.readable.EntityRowHandler<RESULT> handler, Class<? extends RESULT> entityType)
      Overrides:
      delegateSelectCursor in class org.dbflute.bhv.AbstractBehaviorReadable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • delegateSelectBulk

      protected <RESULT extends ENTITY> void delegateSelectBulk(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.readable.EntityRowHandler<List<RESULT>> handler, Class<? extends RESULT> entityType)

    • delegateBulkRequest

      protected void delegateBulkRequest(org.dbflute.cbean.ConditionBean cb, Function<org.opensearch.search.SearchHits,Boolean> handler)

    • deleteScrollContext

      protected void deleteScrollContext(String scrollId)

    • doReadNextVal

      protected Number doReadNextVal()
      Specified by:
      doReadNextVal in class org.dbflute.bhv.AbstractBehaviorReadable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • createListResultBean

      protected <RESULT extends org.dbflute.Entity> org.dbflute.cbean.result.ListResultBean<RESULT> createListResultBean(org.dbflute.cbean.ConditionBean cb, List<RESULT> selectedList)
      Overrides:
      createListResultBean in class org.dbflute.bhv.AbstractBehaviorReadable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • delegateInsert

      protected int delegateInsert(org.dbflute.Entity entity, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)
      Overrides:
      delegateInsert in class org.dbflute.bhv.AbstractBehaviorWritable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • createInsertRequest

      protected org.opensearch.action.index.IndexRequestBuilder createInsertRequest(EsAbstractEntity esEntity)

    • delegateUpdate

      protected int delegateUpdate(org.dbflute.Entity entity, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)
      Overrides:
      delegateUpdate in class org.dbflute.bhv.AbstractBehaviorWritable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • createUpdateRequest

      protected org.opensearch.action.index.IndexRequestBuilder createUpdateRequest(EsAbstractEntity esEntity)

    • toSource

      protected Map<String,Object> toSource(EsAbstractEntity esEntity)

    • delegateDelete

      protected int delegateDelete(org.dbflute.Entity entity, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
      Overrides:
      delegateDelete in class org.dbflute.bhv.AbstractBehaviorWritable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • createDeleteRequest

      protected org.opensearch.action.delete.DeleteRequestBuilder createDeleteRequest(EsAbstractEntity esEntity)

    • delegateQueryDelete

      protected int delegateQueryDelete(org.dbflute.cbean.ConditionBean cb, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
      Overrides:
      delegateQueryDelete in class org.dbflute.bhv.AbstractBehaviorWritable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • delegateBatchInsert

      protected int[] delegateBatchInsert(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.InsertOption<? extends org.dbflute.cbean.ConditionBean> option)
      Overrides:
      delegateBatchInsert in class org.dbflute.bhv.AbstractBehaviorWritable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • delegateBatchUpdate

      protected int[] delegateBatchUpdate(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.UpdateOption<? extends org.dbflute.cbean.ConditionBean> option)
      Overrides:
      delegateBatchUpdate in class org.dbflute.bhv.AbstractBehaviorWritable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • delegateBatchDelete

      protected int[] delegateBatchDelete(List<? extends org.dbflute.Entity> entityList, org.dbflute.bhv.writable.DeleteOption<? extends org.dbflute.cbean.ConditionBean> option)
      Overrides:
      delegateBatchDelete in class org.dbflute.bhv.AbstractBehaviorWritable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • delegateBatchRequest

      protected <BUILDER> int[] delegateBatchRequest(List<? extends org.dbflute.Entity> entityList, Function<EsAbstractEntity,BUILDER> call)

    • createPlainUpdateOption

      protected org.dbflute.bhv.writable.UpdateOption<CB> createPlainUpdateOption()
      Overrides:
      createPlainUpdateOption in class org.dbflute.bhv.AbstractBehaviorWritable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • isCompatibleBatchInsertDefaultEveryColumn

      protected boolean isCompatibleBatchInsertDefaultEveryColumn()
      Overrides:
      isCompatibleBatchInsertDefaultEveryColumn in class org.dbflute.bhv.AbstractBehaviorWritable<ENTITY extends org.dbflute.Entity,CB extends org.dbflute.cbean.ConditionBean>

    • setSizeForDelete

      public void setSizeForDelete(int sizeForDelete)

    • setScrollForDelete

      public void setScrollForDelete(String scrollForDelete)

    • setSizeForCursor

      public void setSizeForCursor(int sizeForCursor)

    • setScrollForCursor

      public void setScrollForCursor(String scrollForCursor)

    • setSearchTimeout

      public void setSearchTimeout(String searchTimeout)

    • setIndexTimeout

      public void setIndexTimeout(String indexTimeout)

    • setScrollSearchTimeout

      public void setScrollSearchTimeout(String scrollSearchTimeout)

    • setBulkTimeout

      public void setBulkTimeout(String bulkTimeout)

    • setDeleteTimeout

      public void setDeleteTimeout(String deleteTimeout)

    • setRefreshTimeout

      public void setRefreshTimeout(String refreshTimeout)

    • toStringArray

      protected String[] toStringArray(Object value)

    • toLocalDateTime

      protected LocalDateTime toLocalDateTime(Object value)

    • toDate

      protected Date toDate(Object value)

    • getSearchHits

      protected org.opensearch.search.SearchHits getSearchHits(org.opensearch.action.search.SearchResponse response)