- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for hasFailure (0.15 sec)
-
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsUrlQueueService.java
builder.add(updateRequest); } return builder.execute(); }); if (bulkResponse.hasFailures()) { throw new EsAccessException(bulkResponse.buildFailureMessage()); } final String sid = scrollId;
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 12.9K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
bufferedList.add(target); if (bufferedList.size() >= bulkBufferSize) { final BulkResponse response = doInsertAll(bufferedList, opType); if (response.hasFailures()) { final String failureMessage = buildFailureMessage(response, ignoreAlreadyExists); if (failureMessage.length() > 0) {
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Apr 04 09:58:36 UTC 2024 - 23.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/model/StateTransitionController.java
throwFailure(); return false; } @Override public ExecutionResult<Void> asResult() { return failure.asFailure(); } @Override public boolean inStateAndNotTransitioning(T toState) { throwFailure(); return false; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 03 03:31:44 UTC 2023 - 20.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
final BulkResponse bulkResponse = bulkRequestBuiler.execute().actionGet(settings.getBulkTimeout()); if (bulkResponse.hasFailures()) { throw new SuggesterException(bulkResponse.buildFailureMessage()); }
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 11.7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tensor_array_ops_decomposition.cc
// Convert int64 to int64_t. llvm::SmallVector<int64_t, 8> dims(shape.begin(), shape.end()); return dims; } bool has_failure = false; auto elem_type = cutil::GetElementTypeFromAccess( ta.getHandle(), module, [&](Operation* user) -> std::optional<Type> { if (has_failure) return std::nullopt; if (auto write = llvm::dyn_cast<TF::TensorArrayWriteV3Op>(user)) { return write.getValue().getType();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Mar 02 20:41:19 UTC 2023 - 40.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchHelper.java
consumer.accept(builder); try { final BulkResponse response = builder.execute().get(); if (response.hasFailures()) { throw new SearchEngineClientException(response.buildFailureMessage()); } return true; } catch (final InterruptedException e) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.8K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
} return bulkRequest.execute(); }); if (bulkResponse.hasFailures()) { throw new EsAccessException(bulkResponse.buildFailureMessage()); } final String sid = scrollId;
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 19.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/allcommon/EsAbstractBehavior.java
} count += hits.length; final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout); if (bulkResponse.hasFailures()) { throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage()); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 26.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/log/allcommon/EsAbstractBehavior.java
} count += hits.length; final BulkResponse bulkResponse = bulkRequest.execute().actionGet(bulkTimeout); if (bulkResponse.hasFailures()) { throw new IllegalBehaviorStateException(bulkResponse.buildFailureMessage()); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 26.4K bytes - Viewed (0) -
platforms/core-runtime/internal-instrumentation-processor/src/main/java/org/gradle/internal/instrumentation/processor/codegen/jvmbytecode/InterceptJvmCallsGenerator.java
import org.gradle.internal.instrumentation.model.ParameterKindInfo; import org.gradle.internal.instrumentation.model.RequestExtra; import org.gradle.internal.instrumentation.processor.codegen.HasFailures.FailureInfo; import org.gradle.internal.instrumentation.processor.codegen.JavadocUtils; import org.gradle.internal.instrumentation.processor.codegen.RequestGroupingInstrumentationClassSourceGenerator;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 10 18:50:01 UTC 2024 - 27.4K bytes - Viewed (0)