- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 375 for jstream (0.13 sec)
-
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
try { ist.interrupt(); } catch (final Exception e) { logger.warn("Could not interrupt a thread of an input stream.", e); } final CountDownLatch latch = new CountDownLatch(3); final Process process = jobProcess.getProcess(); new Thread(() -> { try {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 6.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/SearchLogService.java
params.put("User Agent", e.getUserAgent()); e.getSearchFieldLogList().stream().forEach(p -> { params.put(p.getFirst(), p.getSecond()); }); e.getRequestHeaderList().stream().forEach(p -> { params.put(p.getFirst(), p.getSecond()); }); return params; }).get(); }
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 28.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java
buf.append(roleTypeList.stream().sorted().collect(Collectors.joining(","))); } @SuppressWarnings("unchecked") final List<String> virtualHostList = (List<String>) dataMap.get(fessConfig.getIndexFieldVirtualHost()); if (virtualHostList != null && !virtualHostList.isEmpty()) { buf.append(";v="); buf.append(virtualHostList.stream().sorted().collect(Collectors.joining(",")));
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/stemmeroverride/AdminDictStemmeroverrideAction.java
verifyTokenKeep(() -> downloadpage(form.dictId)); return stemmerOverrideService.getStemmerOverrideFile(form.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })).orElseGet(() -> {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 18.6K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/app/web/admin/storage/AdminStorageAction.java
final PutObjectArgs args = PutObjectArgs.builder().bucket(fessConfig.getStorageBucket()).object(objectName) .stream(in, uploadFile.getFileSize(), -1).contentType("application/octet-stream").build(); minioClient.putObject(args); } catch (final Exception e) { throw new StorageException("Failed to upload " + objectName, e); } }
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 19.9K bytes - Viewed (0) -
internal/config/crypto_test.go
if err != nil { t.Fatalf("Test %d: failed to encrypt stream: %v", i, err) } data, err := io.ReadAll(ciphertext) if err != nil { t.Fatalf("Test %d: failed to encrypt stream: %v", i, err) } plaintext, err := Decrypt(KMS, bytes.NewReader(data), test.Context) if err != nil { t.Fatalf("Test %d: failed to decrypt stream: %v", i, err) } data, err = io.ReadAll(plaintext) if err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 3.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ds/callback/IndexUpdateCallbackImpl.java
final String[] oldLabels = DocumentUtil.getValue(dataMap, fessConfig.getIndexFieldLabel(), String[].class); StreamUtil.stream(oldLabels).of(stream -> stream.forEach(newLabelSet::add)); matchedLabelSet.stream().forEach(newLabelSet::add); dataMap.put(fessConfig.getIndexFieldLabel(), newLabelSet.toArray(new String[newLabelSet.size()])); }
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 7.9K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
"github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) // Reader - JSON record reader for S3Select. type Reader struct { args *json.ReaderArgs input chan simdjson.Stream decoded chan simdjson.Object // err will only be returned after decoded has been closed. err *error readCloser io.ReadCloser onReaderExit func() exitReader chan struct{}
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java
if (logLevel != null) { cmdList.add("-Dfess.log.level=" + logLevel); } stream(fessConfig.getJvmThumbnailOptionsAsArray()) .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(value -> cmdList.add(value))); File ownTmpDir = null; final String tmpDir = System.getProperty("java.io.tmpdir");
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 10.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/SuggestJob.java
addSystemProperty(cmdList, "fess.log.level", null, null); } else { cmdList.add("-Dfess.log.level=" + logLevel); } stream(fessConfig.getJvmSuggestOptionsAsArray()) .of(stream -> stream.filter(StringUtil::isNotBlank).forEach(value -> cmdList.add(value))); File ownTmpDir = null; final String tmpDir = System.getProperty("java.io.tmpdir");
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Sun Jun 23 04:13:47 UTC 2024 - 10K bytes - Viewed (0)