Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for BufferPool (0.09 sec)

  1. internal/s3select/csv/reader.go

    			columns := append(make([]string, 0, len(record)), record...)
    			r.columnNames = columns
    		}
    	}
    
    	r.bufferPool.New = func() interface{} {
    		return make([]byte, csvSplitSize+1024)
    	}
    
    	// Return first block
    	next, nextErr := r.nextSplit(csvSplitSize, r.bufferPool.Get().([]byte))
    	// Check if first block is valid.
    	if !utf8.Valid(next) {
    		return errInvalidTextEncodingError()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. internal/s3select/json/preader.go

    	input       chan *queueItem // input for workers
    	queue       chan *queueItem // output from workers in order
    	err         error           // global error state, only touched by Reader.Read
    	bufferPool  sync.Pool       // pool of []byte objects for input
    	kvDstPool   sync.Pool       // pool of []jstream.KV used for output
    	close       chan struct{}   // used for shutting down the splitter before end of stream
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/timer/SystemMonitorTarget.java

    import org.opensearch.core.xcontent.ToXContent;
    import org.opensearch.core.xcontent.XContentBuilder;
    import org.opensearch.monitor.jvm.JvmStats;
    import org.opensearch.monitor.jvm.JvmStats.BufferPool;
    import org.opensearch.monitor.jvm.JvmStats.Classes;
    import org.opensearch.monitor.jvm.JvmStats.GarbageCollectors;
    import org.opensearch.monitor.jvm.JvmStats.Mem;
    import org.opensearch.monitor.jvm.JvmStats.Threads;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

    import org.lastaflute.web.response.JsonResponse;
    import org.opensearch.action.admin.cluster.health.ClusterHealthResponse;
    import org.opensearch.monitor.jvm.JvmStats;
    import org.opensearch.monitor.jvm.JvmStats.BufferPool;
    import org.opensearch.monitor.jvm.JvmStats.Classes;
    import org.opensearch.monitor.jvm.JvmStats.GarbageCollectors;
    import org.opensearch.monitor.jvm.JvmStats.Mem;
    import org.opensearch.monitor.jvm.JvmStats.Threads;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12.1K bytes
    - Viewed (0)
Back to top