Search Options

Results per page
Sort
Preferred Languages
Advance

Results 501 - 510 of 835 for streams (0.08 sec)

  1. internal/s3select/csv/record.go

    	w.Flush()
    	return w.Error()
    }
    
    // WriteJSON - encodes to JSON data.
    func (r *Record) WriteJSON(writer io.Writer) error {
    	var kvs jstream.KVS = make([]jstream.KV, 0, len(r.columnNames))
    	for i, cn := range r.columnNames {
    		if i < len(r.csvRecord) {
    			kvs = append(kvs, jstream.KV{Key: cn, Value: r.csvRecord[i]})
    		}
    	}
    	return json.NewEncoder(writer).Encode(kvs)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

            stats.put("fs", getFsObj());
            return asJson(new ApiStatsResponse().stats(stats).status(ApiResult.Status.OK).result());
        }
    
        private FsObj[] getFsObj() {
            return Arrays.stream(File.listRoots()).map(f -> {
                final FsObj fsObj = new FsObj();
                fsObj.path = f.getAbsolutePath();
                fsObj.free = f.getFreeSpace();
                fsObj.total = f.getTotalSpace();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  3. 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: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  4. 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: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/TreeMultiset.java

      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeObject(elementSet().comparator());
        Serialization.writeMultiset(this, stream);
      }
    
      @J2ktIncompatible
      @GwtIncompatible // java.io.ObjectInputStream
      private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 34.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/io/TestCharSink.java

      }
    
      @Override
      public boolean wasStreamClosed() {
        return byteSink.wasStreamClosed();
      }
    
      @Override
      public Writer openStream() throws IOException {
        // using TestByteSink's output stream to get option behavior, so flush to it on every write
        return new FilterWriter(new OutputStreamWriter(byteSink.openStream(), UTF_8)) {
          @Override
          public void write(int c) throws IOException {
            super.write(c);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:22:54 UTC 2024
    - 2K bytes
    - Viewed (0)
  7. internal/s3select/parquet/reader.go

    		}
    		return nil, errParquetParsingError(err)
    	}
    
    	kvs := jstream.KVS{}
    	for _, col := range pr.r.Columns() {
    
    		var value interface{}
    		if v, ok := nextRow[col.FlatName()]; ok {
    			value, err = convertFromAnnotation(col.Element(), v)
    			if err != nil {
    				return nil, errParquetParsingError(err)
    			}
    		}
    		kvs = append(kvs, jstream.KV{Key: col.FlatName(), Value: value})
    	}
    
    	// Reuse destination if we can.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 20 18:31:45 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  9. compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java

            saveLayout(writer, typed);
        }
    
        /**
         * Store a properties into a output stream, preserving comments, special character, etc.
         * This method is mainly to be compatible with the java.util.Properties class.
         *
         * @param os an output stream.
         * @param comment this parameter is ignored as this Properties
         * @throws IOException If storing fails
         */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  10. guava/src/com/google/common/collect/TreeMultiset.java

      private void writeObject(ObjectOutputStream stream) throws IOException {
        stream.defaultWriteObject();
        stream.writeObject(elementSet().comparator());
        Serialization.writeMultiset(this, stream);
      }
    
      @J2ktIncompatible
      @GwtIncompatible // java.io.ObjectInputStream
      private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
        stream.defaultReadObject();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 34.5K bytes
    - Viewed (0)
Back to top