- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 375 for jstream (0.13 sec)
-
internal/s3select/csv/args.go
args.QuoteEscapeCharacter = defaultQuoteEscapeCharacter args.CommentCharacter = defaultCommentCharacter args.AllowQuotedRecordDelimiter = false for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { tagName := se.Name.Local switch tagName {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 20 18:31:45 UTC 2024 - 5.7K bytes - Viewed (0) -
buildscripts/cicd-corpus/disk2/bucket/testobj/xl.meta
�CSumAlgo�PartNums��PartETags��PartSizes�� ը�PartASizes�� ը�Size� ը�MTime�����çMetaSys��x-minio-internal-replica-status�REPLICA�"x-minio-internal-replica-timestamp�2022-03-20T15:15:01.584169645Z�MetaUsr��content-type�application/octet-stream�x-amz-storage-class�STANDARD�X-Amz-Replication-Status�REPLICA�etag� 9587ddd31fead633830366f45d221d56�;��...
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Apr 20 19:49:05 UTC 2022 - 531 bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/dict/mapping/AdminDictMappingAction.java
verifyTokenKeep(() -> downloadpage(form.dictId)); return charMappingService.getCharMappingFile(form.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })).orElseGet(() -> { throwValidationError(messages -> messages.addErrorsFailedToDownloadMappingFile(GLOBAL),
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 19.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java
*/ package org.codelibs.fess.app.web.api.admin.scheduler; import static org.codelibs.fess.app.web.admin.scheduler.AdminSchedulerAction.getScheduledJob; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.Constants; import org.codelibs.fess.app.pager.SchedulerPager;
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 7.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/duplicatehost/ApiAdminDuplicatehostAction.java
*/ package org.codelibs.fess.app.web.api.admin.duplicatehost; import static org.codelibs.fess.app.web.admin.duplicatehost.AdminDuplicatehostAction.getDuplicateHost; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.DuplicateHostPager; import org.codelibs.fess.app.service.DuplicateHostService;
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 6.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/IndexingHelper.java
final ThumbnailManager thumbnailManager = ComponentUtil.getThumbnailManager(); final String thumbnailField = fessConfig.getIndexFieldThumbnail(); docList.stream().forEach(doc -> { if (!thumbnailManager.offer(doc)) { if (logger.isDebugEnabled()) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 16.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/reqheader/ApiAdminReqheaderAction.java
*/ package org.codelibs.fess.app.web.api.admin.reqheader; import static org.codelibs.fess.app.web.admin.reqheader.AdminReqheaderAction.getRequestHeader; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.ReqHeaderPager; import org.codelibs.fess.app.service.RequestHeaderService;
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 6.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/webauth/ApiAdminWebauthAction.java
*/ package org.codelibs.fess.app.web.api.admin.webauth; import static org.codelibs.fess.app.web.admin.webauth.AdminWebauthAction.getWebAuthentication; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.app.pager.WebAuthPager; import org.codelibs.fess.app.service.WebAuthenticationService;
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 6.8K bytes - Viewed (0) -
cmd/metacache-walk.go
} // supported FS for Nlink optimization in readdir. const ( xfs = "XFS" ext4 = "EXT4" ) // WalkDir will traverse a directory and return all entries found. // On success a sorted meta cache stream will be returned. // Metadata has data stripped, if any. func (s *xlStorage) WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) (err error) { legacyFS := !(s.fsType == xfs || s.fsType == ext4) s.RLock()
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Jun 01 05:17:37 UTC 2024 - 12.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SearchHelper.java
import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Map.Entry; import java.util.Set; import java.util.concurrent.ExecutionException; import java.util.function.Consumer; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.exception.InterruptedRuntimeException; import org.codelibs.core.lang.StringUtil;
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 19.1K bytes - Viewed (0)