- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for selectCursor (0.11 sec)
-
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
final long timeout = fessConfig.getIndexBackupLogLoadTimeoutAsInteger().longValue(); return writer -> { final SearchLogBhv bhv = ComponentUtil.getComponent(SearchLogBhv.class); bhv.selectCursor(cb -> { cb.query().matchAll(); cb.query().addOrderBy_RequestedAt_Asc(); }, new LogEntityRowHandler<SearchLog>() { @Override
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 29.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/CrawlJobTest.java
scheduledJobs.add(job1); scheduledJobs.add(job2); scheduledJobs.add(job3); ComponentUtil.register(new ScheduledJobBhv() { @Override public void selectCursor(CBCall<ScheduledJobCB> cbLambda, EntityRowHandler<ScheduledJob> entityLambda) { for (ScheduledJob job : scheduledJobs) { entityLambda.handle(job); } }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 25K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/RoleService.java
ComponentUtil.getLdapManager().delete(role); roleBhv.delete(role, op -> { op.setRefreshPolicy(Constants.TRUE); }); userBhv.selectCursor(cb -> cb.query().setRoles_Equal(role.getId()), entity -> { entity.setRoles( stream(entity.getRoles()).get(stream -> stream.filter(s -> !s.equals(role.getId())).toArray(n -> new String[n])));
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 4.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/GroupService.java
ComponentUtil.getLdapManager().delete(group); groupBhv.delete(group, op -> { op.setRefreshPolicy(Constants.TRUE); }); userBhv.selectCursor(cb -> cb.query().setGroups_Equal(group.getId()), entity -> { entity.setGroups( stream(entity.getGroups()).get(stream -> stream.filter(s -> !s.equals(group.getId())).toArray(n -> new String[n])));
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 5.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/ScheduledJobService.java
}); } /** * Starts all available scheduled jobs. * @param cron The cron scheduler. */ public void start(final LaCron cron) { scheduledJobBhv.selectCursor(cb -> { cb.query().setAvailable_Equal(Constants.T); cb.query().addOrderBy_SortOrder_Asc(); cb.query().addOrderBy_Name_Asc(); }, scheduledJob -> { try {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 6.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/log/bsbhv/BsClickLogBhv.java
public PagingResultBean<ClickLog> selectPage(CBCall<ClickLogCB> cbLambda) { // #pending same? return (PagingResultBean<ClickLog>) facadeSelectList(createCB(cbLambda)); } public void selectCursor(CBCall<ClickLogCB> cbLambda, EntityRowHandler<ClickLog> entityLambda) { facadeSelectCursor(createCB(cbLambda), entityLambda); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 9.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/user/bsbhv/BsRoleBhv.java
} public PagingResultBean<Role> selectPage(CBCall<RoleCB> cbLambda) { // #pending same? return (PagingResultBean<Role>) facadeSelectList(createCB(cbLambda)); } public void selectCursor(CBCall<RoleCB> cbLambda, EntityRowHandler<Role> entityLambda) { facadeSelectCursor(createCB(cbLambda), entityLambda); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 8.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsFailureUrlBhv.java
public PagingResultBean<FailureUrl> selectPage(CBCall<FailureUrlCB> cbLambda) { // #pending same? return (PagingResultBean<FailureUrl>) facadeSelectList(createCB(cbLambda)); } public void selectCursor(CBCall<FailureUrlCB> cbLambda, EntityRowHandler<FailureUrl> entityLambda) { facadeSelectCursor(createCB(cbLambda), entityLambda); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 9.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsRequestHeaderBhv.java
// #pending same? return (PagingResultBean<RequestHeader>) facadeSelectList(createCB(cbLambda)); } public void selectCursor(CBCall<RequestHeaderCB> cbLambda, EntityRowHandler<RequestHeader> entityLambda) { facadeSelectCursor(createCB(cbLambda), entityLambda); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 9.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsThumbnailQueueBhv.java
// #pending same? return (PagingResultBean<ThumbnailQueue>) facadeSelectList(createCB(cbLambda)); } public void selectCursor(CBCall<ThumbnailQueueCB> cbLambda, EntityRowHandler<ThumbnailQueue> entityLambda) { facadeSelectCursor(createCB(cbLambda), entityLambda); }
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 9.8K bytes - Viewed (0)