Search Options

Results per page
Sort
Preferred Languages
Advance

Results 661 - 670 of 1,396 for upsert (0.13 sec)

  1. guava/src/com/google/common/collect/CompactHashing.java

     *
     * @author Jon Noack
     */
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    final class CompactHashing {
      private CompactHashing() {}
    
      /** Indicates blank table entries. */
      static final byte UNSET = 0;
    
      /** Number of bits used to store the numbers of hash table bits (max 30). */
      private static final int HASH_TABLE_BITS_MAX_BITS = 5;
    
      /** Use high bits of metadata for modification count. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 15:34:52 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/CompactHashSet.java

        int minimumTableSize = CompactHashing.tableSize(size);
        int mask = hashTableMask();
        if (minimumTableSize < mask) { // smaller table size will always be less than current mask
          resizeTable(mask, minimumTableSize, UNSET, UNSET);
        }
      }
    
      @Override
      public void clear() {
        if (needsAllocArrays()) {
          return;
        }
        incrementModCount();
        Set<E> delegate = delegateOrNull();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  3. internal/bucket/replication/datatypes_gen.go

    		zb0001, bts, err = msgp.ReadStringBytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = StatusType(zb0001)
    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z StatusType) Msgsize() (s int) {
    	s = msgp.StringPrefixSize + len(string(z))
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 19:08:18 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/core/io/ClassTraversalTest.java

    package org.codelibs.core.io;
    
    import static org.hamcrest.CoreMatchers.is;
    import static org.hamcrest.CoreMatchers.not;
    import static org.hamcrest.CoreMatchers.notNullValue;
    import static org.junit.Assert.assertThat;
    import static org.junit.Assert.assertTrue;
    
    import java.io.File;
    import java.net.JarURLConnection;
    import java.net.URL;
    import java.util.zip.ZipInputStream;
    
    import junit.framework.TestCase;
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  5. docs_src/settings/app02/test_main.py

        return Settings(admin_email="******@****.***")
    
    
    app.dependency_overrides[get_settings] = get_settings_override
    
    
    def test_app():
        response = client.get("/info")
        data = response.json()
        assert data == {
            "app_name": "Awesome API",
            "admin_email": "******@****.***",
            "items_per_user": 50,
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Jul 29 09:26:07 UTC 2021
    - 515 bytes
    - Viewed (0)
  6. docs/multi-user/admin/README.md

    ```
    
    Create a new admin user `admin1` on MinIO use `mc admin user`.
    
    ```
    mc admin user add myminio admin1 admin123
    ```
    
    Once the user is successfully created you can now apply the `userManage` policy for this user.
    
    ```
    mc admin policy attach myminio userManager --user=admin1
    ```
    
    This admin user will then be allowed to perform create/delete user operations via `mc admin user`
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 21 06:38:06 UTC 2023
    - 4.5K bytes
    - Viewed (0)
  7. docs/de/docs/advanced/async-tests.md

    Schauen wir uns an, wie wir das machen können.
    
    ## pytest.mark.anyio
    
    Wenn wir in unseren Tests asynchrone Funktionen aufrufen möchten, müssen unsere Testfunktionen asynchron sein. AnyIO stellt hierfür ein nettes Plugin zur Verfügung, mit dem wir festlegen können, dass einige Testfunktionen asynchron aufgerufen werden sollen.
    
    ## HTTPX
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:34:47 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/it/admin/PluginTests.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.fess.it.admin;
    
    import static org.hamcrest.Matchers.equalTo;
    import static org.junit.Assert.assertFalse;
    import static org.junit.Assert.assertTrue;
    
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    
    import org.codelibs.core.lang.ThreadUtil;
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jul 01 02:20:48 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/core/exception/ConverterRuntimeExceptionTest.java

     * governing permissions and limitations under the License.
     */
    package org.codelibs.core.exception;
    
    import static org.hamcrest.CoreMatchers.is;
    import static org.junit.Assert.assertThat;
    
    import org.junit.Test;
    
    /**
     * @author higa
     */
    public class ConverterRuntimeExceptionTest {
    
        /**
         * @throws Exception
         */
        @Test
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/UrlQueueService.java

     *
     */
    public interface UrlQueueService<QUEUE extends UrlQueue<?>> {
    
        void updateSessionId(String oldSessionId, String newSessionId);
    
        void add(String sessionId, String url);
    
        void insert(QUEUE urlQueue);
    
        void delete(String sessionId);
    
        void deleteAll();
    
        void offerAll(String sessionId, List<QUEUE> newUrlQueueList);
    
        QUEUE poll(String sessionId);
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 1.3K bytes
    - Viewed (0)
Back to top