@Test public void testProcessorBatchSize(){ BufferManager bm = BufferManagerFactory.createBufferManager(); int processorBatchSize = bm.getProcessorBatchSize(); List<ElementSymbol> elements = new ArrayList<ElementSymbol>(); ElementSymbol a = new ElementSymbol("a"); a.setType(DataTypeManager.DefaultDataClasses.INTEGER); ElementSymbol b = new ElementSymbol("b"); b.setType(DataTypeManager.DefaultDataClasses.STRING); elements.add(a); assertEquals(processorBatchSize * 8, bm.getProcessorBatchSize(elements)); elements.add(b); assertEquals(processorBatchSize * 4, bm.getProcessorBatchSize(elements)); elements.add(b); assertEquals(processorBatchSize * 2, bm.getProcessorBatchSize(elements)); elements.add(b); elements.add(b); assertEquals(processorBatchSize, bm.getProcessorBatchSize(elements)); elements.addAll(Collections.nCopies(28, b)); assertEquals(processorBatchSize/2, bm.getProcessorBatchSize(elements)); elements.addAll(Collections.nCopies(100, b)); assertEquals(processorBatchSize/4, bm.getProcessorBatchSize(elements)); elements.addAll(Collections.nCopies(375, b)); assertEquals(processorBatchSize/8, bm.getProcessorBatchSize(elements)); }
@Override public int getProcessorBatchSize() { return this.processorBatchSize; }
BufferManagerImpl implements BufferManager, ReplicatedObject<String>, SessionKiller { @Override public int getProcessorBatchSize() { return this.processorBatchSize; } }
BufferManagerImpl implements BufferManager, ReplicatedObject<String>, SessionKiller { @Override public int getProcessorBatchSize() { return this.processorBatchSize; } BufferManagerImpl();  BufferManagerImpl(boolean sharedTimer); }
BufferManagerImpl implements BufferManager, ReplicatedObject<String>, SessionKiller { @Override public int getProcessorBatchSize() { return this.processorBatchSize; } BufferManagerImpl();  BufferManagerImpl(boolean sharedTimer); long getBatchesAdded(); long getReadCount(); long getWriteCount(); long getReadAttempts(); @Override int getMaxProcessingSize(); long getReserveBatchBytes(); @Override int getProcessorBatchSize(); void setTargetBytesPerRow(int targetBytesPerRow); void setProcessorBatchSize(int processorBatchSize); @Override TupleBuffer createTupleBuffer(final List elements, String groupName,
            TupleSourceType tupleSourceType); STree createSTree(final List<? extends Expression> elements, String groupName, int keyLength); @Override FileStore createFileStore(String name); @Override long getMaxStorageSpace(); Cache getCache(); void setMaxActivePlans(int maxActivePlans); void setMaxProcessingKB(int maxProcessingKB); void setMaxReserveKB(int maxReserveBatchKB); @Override void initialize(); @Override void releaseOrphanedBuffers(long count); @Override void releaseBuffers(int count); @Override int reserveBuffers(int count, BufferReserveMode mode); @Override int reserveBuffersBlocking(int count, long[] val, boolean force); @Override int getProcessorBatchSize(List<? extends Expression> schema); @Override int getSchemaSize(List<? extends Expression> elements); void shutdown(); @Override void addTupleBuffer(TupleBuffer tb); @Override void distributeTupleBuffer(String uuid, TupleBuffer tb); @Override TupleBuffer getTupleBuffer(String id); void setUseWeakReferences(boolean useWeakReferences); @Override void getState(OutputStream ostream); @Override void getState(String state_id, OutputStream ostream); @Override void setState(InputStream istream); @Override void setState(String state_id, InputStream istream); @Override void setAddress(Serializable address); @Override void droppedMembers(Collection<Serializable> addresses); void setInlineLobs(boolean inlineLobs); int getMaxReserveKB(); void setCache(Cache cache); int getMemoryCacheEntries(); long getActiveBatchBytes(); @Override boolean hasState(String stateId); long getReferenceHits(); @Override void persistLob(Streamable<?> lob, FileStore store,
            byte[] bytes); void invalidCacheGroup(Long gid); @Override void setOptions(Options options); @Override Options getOptions(); void setStorageManager(StorageManager ssm); void setMaxSessionBatchManagerSizeEstimate(
            long maxSessionBatchManagerSizeEstimate); void setMaxBatchManagerSizeEstimate(
            long maxBatchManagerSizeEstimate); void setEnforceMaxBatchManagerSizeEstimate(
            boolean enforceMaxBatchManagerSizeEstimate); @Override boolean killLargestConsumer(); void setSessionService(SessionService sessionService); }
BufferManagerImpl implements BufferManager, ReplicatedObject<String>, SessionKiller { @Override public int getProcessorBatchSize() { return this.processorBatchSize; } BufferManagerImpl();  BufferManagerImpl(boolean sharedTimer); long getBatchesAdded(); long getReadCount(); long getWriteCount(); long getReadAttempts(); @Override int getMaxProcessingSize(); long getReserveBatchBytes(); @Override int getProcessorBatchSize(); void setTargetBytesPerRow(int targetBytesPerRow); void setProcessorBatchSize(int processorBatchSize); @Override TupleBuffer createTupleBuffer(final List elements, String groupName,
            TupleSourceType tupleSourceType); STree createSTree(final List<? extends Expression> elements, String groupName, int keyLength); @Override FileStore createFileStore(String name); @Override long getMaxStorageSpace(); Cache getCache(); void setMaxActivePlans(int maxActivePlans); void setMaxProcessingKB(int maxProcessingKB); void setMaxReserveKB(int maxReserveBatchKB); @Override void initialize(); @Override void releaseOrphanedBuffers(long count); @Override void releaseBuffers(int count); @Override int reserveBuffers(int count, BufferReserveMode mode); @Override int reserveBuffersBlocking(int count, long[] val, boolean force); @Override int getProcessorBatchSize(List<? extends Expression> schema); @Override int getSchemaSize(List<? extends Expression> elements); void shutdown(); @Override void addTupleBuffer(TupleBuffer tb); @Override void distributeTupleBuffer(String uuid, TupleBuffer tb); @Override TupleBuffer getTupleBuffer(String id); void setUseWeakReferences(boolean useWeakReferences); @Override void getState(OutputStream ostream); @Override void getState(String state_id, OutputStream ostream); @Override void setState(InputStream istream); @Override void setState(String state_id, InputStream istream); @Override void setAddress(Serializable address); @Override void droppedMembers(Collection<Serializable> addresses); void setInlineLobs(boolean inlineLobs); int getMaxReserveKB(); void setCache(Cache cache); int getMemoryCacheEntries(); long getActiveBatchBytes(); @Override boolean hasState(String stateId); long getReferenceHits(); @Override void persistLob(Streamable<?> lob, FileStore store,
            byte[] bytes); void invalidCacheGroup(Long gid); @Override void setOptions(Options options); @Override Options getOptions(); void setStorageManager(StorageManager ssm); void setMaxSessionBatchManagerSizeEstimate(
            long maxSessionBatchManagerSizeEstimate); void setMaxBatchManagerSizeEstimate(
            long maxBatchManagerSizeEstimate); void setEnforceMaxBatchManagerSizeEstimate(
            boolean enforceMaxBatchManagerSizeEstimate); @Override boolean killLargestConsumer(); void setSessionService(SessionService sessionService);  }