- Sort Score
- Result 10 results
- Languages All
Results 271 - 280 of 375 for jstream (0.37 sec)
-
internal/init/init_darwin_amd64.go
"github.com/klauspost/cpuid/v2" ) func init() { // All MinIO operations must be under UTC. os.Setenv("TZ", "UTC") // Temporary workaround for // https://github.com/golang/go/issues/49233 // Keep until upstream has been fixed. cpuid.CPU.Disable(cpuid.AVX512F, cpuid.AVX512BW, cpuid.AVX512CD, cpuid.AVX512DQ, cpuid.AVX512ER, cpuid.AVX512FP16, cpuid.AVX512IFMA, cpuid.AVX512PF, cpuid.AVX512VBMI,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Nov 04 23:44:38 UTC 2022 - 1.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/HtmlTagBasedGenerator.java
import java.io.File; import java.io.IOException; import java.util.Iterator; import java.util.Map; import javax.imageio.ImageIO; import javax.imageio.ImageReadParam; import javax.imageio.ImageReader; import javax.imageio.stream.ImageInputStream; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil; import org.codelibs.core.misc.Tuple3;
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 7.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/score/ScoreBooster.java
.setFetchSource(false).setSize(fessConfig.getPageScoreBoosterMaxFetchSizeAsInteger()).execute().actionGet(requestTimeout); return Arrays.stream(response.getHits().getHits()).map(SearchHit::getId).toArray(n -> new String[n]); }; protected Function<Map<String, Object>, Long> requestHandler = params -> {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/util/ParameterUtil.java
final Pattern properyPattern = Pattern.compile(ComponentUtil.getFessConfig().getAppEncryptPropertyPattern()); final PrimaryCipher cipher = ComponentUtil.getPrimaryCipher(); ParameterUtil.parse(value).entrySet().stream().map(e -> { final String k = e.getKey(); final String v = e.getValue(); if (properyPattern.matcher(k).matches() && !v.startsWith(CIPHER_PREFIX)) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 6.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/DictionaryFile.java
import java.util.Iterator; import java.util.List; import java.util.ListIterator; import org.codelibs.curl.CurlResponse; import org.dbflute.optional.OptionalEntity; import org.lastaflute.web.servlet.request.stream.WrittenStreamOut; public abstract class DictionaryFile<T extends DictionaryItem> { protected DictionaryManager dictionaryManager; protected String id; protected String path;
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 6.8K bytes - Viewed (0) -
docs/orchestration/README.md
|:---------------------------------------------------------------------------------------------------| | [`Kubernetes`](https://min.io/docs/minio/kubernetes/upstream/index.html#quickstart-for-kubernetes) | ## Why is MinIO cloud-native?
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 2.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/cache/CacheAction.java
if (content == null) { saveError(messages -> messages.addErrorsDocidNotFound(GLOBAL, form.docId)); return redirect(ErrorAction.class); } final StreamResponse response = asStream(DocumentUtil.getValue(doc, fessConfig.getIndexFieldDocId(), String.class)) .contentType("text/html; charset=UTF-8").data(content.getBytes(Constants.CHARSET_UTF_8));
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 3.4K bytes - Viewed (0) -
src/cmd/asm/internal/lex/lex.go
// the text of the most recently returned token is, and where it was found. // The underlying scanner elides all spaces except newline, so the input looks like a stream of // Tokens; original spacing is lost but we don't need it. type TokenReader interface { // Next returns the next token. Next() ScanToken // The following methods all refer to the most recent token returned by Next.
Registered: Tue Oct 29 11:13:09 UTC 2024 - Last Modified: Tue Aug 29 18:31:05 UTC 2023 - 4.1K bytes - Viewed (0) -
internal/http/transports.go
TLSClientConfig: &tlsClientConfig, ForceAttemptHTTP2: s.EnableHTTP2, // Go net/http automatically unzip if content-type is // gzip disable this feature, as we are always interested // in raw stream. DisableCompression: true, } // https://github.com/golang/go/issues/23559 // https://github.com/golang/go/issues/42534 // https://github.com/golang/go/issues/43989 // https://github.com/golang/go/issues/33425
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
cmd/storage-interface.go
StatVol(ctx context.Context, volume string) (vol VolInfo, err error) DeleteVol(ctx context.Context, volume string, forceDelete bool) (err error) // WalkDir will walk a directory on disk and return a metacache stream on wr. WalkDir(ctx context.Context, opts WalkDirOptions, wr io.Writer) error // Metadata operations DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) error
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 5.2K bytes - Viewed (0)