List of batchSize() Examples

Examples of batchSize()

com.mongodb.DBCursor.batchSize()
Limits the number of elements returned in one batch. A cursor typically fetches a batch of result objects and store them locally. If batchSize is positive, it represents the size of each batch of objects retrieved. It can be adjusted to optimize performance and limit data transfer. If batchSize is negative, it will limit of number objects returned, that fit within the max batch size limit (usually 4MB), and cursor will be closed. For example if batchSize is -10, then the server will return a maximum of 10 documents and as many as can fit in 4MB, then close the cursor. Note that this feature is different from limit() in that documents must fit within a maximum size, and it removes the need to send a request to close the cursor server-side. The batch size can be changed even after a cursor is iterated, in which case the setting will apply on the next batch retrieval. @param n the number of elements to return in a batch @return
com.netflix.eventbus.spi.Subscribe.batchSize()
org.infinispan.loaders.jpa.configuration.JpaCacheStoreConfiguration.batchSize()
org.infinispan.persistence.jpa.configuration.JpaStoreConfiguration.batchSize()

Examples of com.mongodb.DBCursor.batchSize()

        }
        if (limit > 0) {
            cursor.limit(limit);
        }
        if (batchSize != 0) {
            cursor.batchSize(batchSize);
        }
        if (snapshotted) {
            cursor.snapshot();
        }
        if (sort != null) {

View Full Code Here

Examples of com.netflix.eventbus.spi.Subscribe.batchSize()

                        }
                    }


                    switch (subscribeAnnotation.batchingStrategy()) {
                        case SizeOrAge:
                            if (subscribeAnnotation.batchSize() <= 1) {
                                errors.put(method, String.format(
                                        "Subscriber: %s's Method: %s is annotated with batching strategy: %s but does define a batch size.",
                                        subscriber.getClass(), method.toGenericString(),
                                        subscribeAnnotation.batchingStrategy()));
                            }

View Full Code Here

Examples of org.infinispan.loaders.jpa.configuration.JpaCacheStoreConfiguration.batchSize()

  protected void validateConfig(Cache<VehicleId, Vehicle> vehicleCache) {
     CacheLoaderConfiguration config = vehicleCache.getCacheConfiguration().loaders().cacheLoaders().get(0);
     
     if (config instanceof JpaCacheStoreConfiguration) {
        JpaCacheStoreConfiguration jpaConfig = (JpaCacheStoreConfiguration) config;
        assert jpaConfig.batchSize() == 1;
         assert jpaConfig.entityClass().equals(Vehicle.class) : jpaConfig.entityClass() + " != " + Vehicle.class;
         assert jpaConfig.persistenceUnitName().equals("org.infinispan.loaders.jpa.configurationTest") : jpaConfig.persistenceUnitName() + " != " + "org.infinispan.loaders.jpa.configurationTest";
     } else {
        assert false : "Unknown configuation class " + config.getClass();
     }

View Full Code Here

Examples of org.infinispan.persistence.jpa.configuration.JpaStoreConfiguration.batchSize()

  protected void validateConfig(Cache<VehicleId, Vehicle> vehicleCache) {
     StoreConfiguration config = vehicleCache.getCacheConfiguration().persistence().stores().get(0);
     
     assertTrue(config instanceof JpaStoreConfiguration);
      JpaStoreConfiguration jpaConfig = (JpaStoreConfiguration) config;
      assertEquals(1, jpaConfig.batchSize());
      assertEquals(Vehicle.class, jpaConfig.entityClass());
      assertEquals(PERSISTENCE_UNIT_NAME, jpaConfig.persistenceUnitName());
  }
  
  public void testXmlConfig60() throws IOException {

View Full Code Here

Examples of org.infinispan.persistence.jpa.configuration.JpaStoreConfiguration.batchSize()

   protected void validateConfig(Cache<VehicleId, Vehicle> vehicleCache) {
      StoreConfiguration config = vehicleCache.getCacheConfiguration().persistence().stores().get(0);


      assertTrue(config instanceof JpaStoreConfiguration);
      JpaStoreConfiguration jpaConfig = (JpaStoreConfiguration) config;
      assertEquals(1, jpaConfig.batchSize());
      assertEquals(Vehicle.class, jpaConfig.entityClass());
      assertEquals(PERSISTENCE_UNIT_NAME, jpaConfig.persistenceUnitName());
   }


   public void testXmlConfig() throws IOException {

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.