- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Callback (0.15 sec)
-
src/main/java/org/codelibs/fess/es/user/cbean/ca/bs/BsRoleCA.java
if (queryLambda != null) { queryLambda.callback(cq); } FilterAggregationBuilder builder = regFilterA(name, cq.getQuery()); if (opLambda != null) { opLambda.callback(builder); } if (aggsLambda != null) { RoleCA ca = new RoleCA(); aggsLambda.callback(ca); ca.getAggregationBuilderList().forEach(builder::subAggregation);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 8.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/SearchEngineUtil.java
} public static long scroll(final String index, final Function<SearchHit, Boolean> callback) { final SearchEngineClient client = ComponentUtil.getSearchEngineClient(); return client.<SearchHit> scrollSearch(index, searchRequestBuilder -> true, (searchResponse, hit) -> hit, hit -> callback.apply(hit)); }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 2.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/AbstractDataStore.java
import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.lang.ThreadUtil; import org.codelibs.core.misc.Pair; import org.codelibs.fess.Constants; import org.codelibs.fess.ds.callback.IndexUpdateCallback; import org.codelibs.fess.entity.DataStoreParams; import org.codelibs.fess.es.config.exentity.DataConfig; import org.codelibs.fess.helper.CrawlingInfoHelper; import org.codelibs.fess.helper.SystemHelper;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.3K bytes - Viewed (1) -
src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.ds; import java.util.HashMap; import java.util.Map; import org.codelibs.fess.Constants; import org.codelibs.fess.ds.callback.IndexUpdateCallback; import org.codelibs.fess.entity.DataStoreParams; import org.codelibs.fess.es.config.exentity.DataConfig; import org.codelibs.fess.exception.JobProcessingException;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 4.1K bytes - Viewed (0) -
src/main/resources/fess_ds.xml
"http://dbflute.org/meta/lastadi10.dtd"> <components> <component name="dataStoreFactory" class="org.codelibs.fess.ds.DataStoreFactory"> </component> <component name="indexUpdateCallback" class="org.codelibs.fess.ds.callback.IndexUpdateCallbackImpl" instance="prototype"> </component>
XML - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu May 31 09:46:09 GMT 2018 - 404 bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, * either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.ds.callback; import java.util.HashSet; import java.util.Map; import java.util.Set; import java.util.concurrent.atomic.AtomicLong; import javax.annotation.PostConstruct; import org.apache.logging.log4j.LogManager;
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallback.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, * either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.ds.callback; import java.util.Map; import org.codelibs.fess.entity.DataStoreParams; public interface IndexUpdateCallback { void store(DataStoreParams paramMap, Map<String, Object> dataMap);
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 924 bytes - Viewed (0) -
src/main/java/org/codelibs/fess/mylasta/direction/sponsor/FessMailDeliveryDepartmentCreator.java
protected void async(final AsyncManager asyncManager, final Runnable runnable) { asyncManager.async(new ConcurrentAsyncCall() { @Override public void callback() { runnable.run(); } @Override public boolean asPrimary() { return true; // mail is primary business } });
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/OsddHelperTest.java
final StreamResponse streamResponse = osddHelper.asStream(); assertEquals("text/xml; charset=UTF-8", streamResponse.getContentType()); streamResponse.getStreamCall().callback(new WrittenStreamOut() { @Override public void write(final InputStream ins) throws IOException { assertEquals(""" <?xml version="1.0" encoding="UTF-8"?>
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/DataStore.java
*/ package org.codelibs.fess.ds; import org.codelibs.fess.ds.callback.IndexUpdateCallback; import org.codelibs.fess.entity.DataStoreParams; import org.codelibs.fess.es.config.exentity.DataConfig; public interface DataStore { void store(DataConfig config, IndexUpdateCallback callback, DataStoreParams initParamMap); void stop();
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 962 bytes - Viewed (0)