Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1111 - 1120 of 1,192 for call$ (0.03 sec)

  1. internal/s3select/sql/analysis.go

    		return result
    
    	case sqlFnDateDiff:
    		result.combine(e.DateDiff.Timestamp1.analyze(s))
    		result.combine(e.DateDiff.Timestamp2.analyze(s))
    		return result
    
    	// Handle aggregation function calls
    	case aggFnAvg, aggFnMax, aggFnMin, aggFnSum, aggFnCount:
    		// Initialize accumulator
    		e.aggregate = newAggVal(funcName)
    
    		var exprA qProp
    		if funcName == aggFnCount {
    			if e.Count.StarArg {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 8.5K bytes
    - Viewed (0)
  2. guava/src/com/google/common/io/CharSource.java

        return reader.lines().onClose(() -> closeUnchecked(reader));
      }
    
      @SuppressWarnings("Java7ApiChecker")
      @IgnoreJRERequirement // helper for lines()
      /*
       * If we make these calls inline inside the lambda inside lines(), we get an Animal Sniffer error,
       * despite the @IgnoreJRERequirement annotation there. For details, see ImmutableSortedMultiset.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Base class for tests for emulated {@link AbstractFuture} that allow subclasses to swap in a
     * different "source Future" for {@link AbstractFuture#setFuture} calls.
     */
    @GwtCompatible(emulated = true)
    abstract class AbstractAbstractFutureTest extends TestCase {
      private TestedFuture<Integer> future;
      private AbstractFuture<Integer> delegate;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 15:41:36 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  4. internal/config/lambda/target/webhook.go

    		return false, err
    	}
    	xhttp.DrainBody(resp.Body)
    	// No network failure i.e response from the target means its up
    	return true, nil
    }
    
    // Stat - returns lambda webhook target statistics such as
    // current calls in progress, successfully completed functions
    // failed functions.
    func (target *WebhookTarget) Stat() event.TargetStat {
    	return event.TargetStat{
    		ID:             target.id,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

        // Impact the coordinator if we inserted at the front.
        return insertAt == 0
      }
    
      /**
       * Schedules immediate execution of [Task.tryCancel] on all currently-enqueued tasks. These calls
       * will not be made until any currently-executing task has completed. Tasks that return true will
       * be removed from the execution schedule.
       */
      fun cancelAll() {
        lock.assertNotHeld()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/DenseImmutableTable.java

        for (int i = 0; i < cellList.size(); i++) {
          Cell<R, C, V> cell = cellList.get(i);
          R rowKey = cell.getRowKey();
          C columnKey = cell.getColumnKey();
          // The requireNonNull calls are safe because we construct the indexes with indexMap.
          int rowIndex = requireNonNull(rowKeyToIndex.get(rowKey));
          int columnIndex = requireNonNull(columnKeyToIndex.get(columnKey));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  7. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ForwardingSortedMultiset.java

    import java.util.Iterator;
    import java.util.SortedSet;
    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * A sorted multiset which forwards all its method calls to another sorted multiset. Subclasses
     * should override one or more methods to modify the behavior of the backing multiset as desired per
     * the <a href="http://en.wikipedia.org/wiki/Decorator_pattern">decorator pattern</a>.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jan 23 18:43:40 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  8. istioctl/pkg/metrics/metrics_test.go

    	corev1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    
    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/istioctl/pkg/util/testutil"
    )
    
    // mockPromAPI lets us mock calls to Prometheus API
    type mockPromAPI struct {
    	cannedResponse map[string]prometheus_model.Value
    }
    
    func TestMetricsNoPrometheus(t *testing.T) {
    	cases := []testutil.TestCase{
    		{ // case 0
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 01:35:47 UTC 2024
    - 8K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt

      return (b0 shl 7) + b1
    }
    
    /**
     * An extremely generic binary search that doesn't know what data it's searching over. The caller
     * provides indexes and a comparison function, and this calls that function iteratively.
     *
     * @return the index of the match. If no match is found this is `(-1 - insertionPoint)`, where the
     *     inserting the element at `insertionPoint` will retain sorted order.
     */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Apr 02 11:39:58 UTC 2024
    - 9K bytes
    - Viewed (0)
  10. cmd/handler-api.go

    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	if t.requestsPool == nil {
    		return nil
    	}
    
    	return t.requestsPool
    }
    
    // maxClients throttles the S3 API calls
    func maxClients(f http.HandlerFunc) http.HandlerFunc {
    	return func(w http.ResponseWriter, r *http.Request) {
    		globalHTTPStats.incS3RequestsIncoming()
    
    		if r.Header.Get(globalObjectPerfUserMetadata) == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
Back to top