modules/core/src/main/java/org/apache/fluo/recipes/core/combine/CombineQueue.java [102:135]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public static interface FluentArg3 {
    FluentOptions buckets(int numBuckets);
  }

  /**
   * Part of a fluent API for configuring a combine queue.
   * 
   * @since 1.1.0
   */
  public static interface FluentOptions {
    /**
     * Sets a limit on the amount of serialized updates to read into memory. Additional memory will
     * be used to actually deserialize and process the updates. This limit does not account for
     * object overhead in java, which can be significant.
     *
     * <p>
     * The way memory read is calculated is by summing the length of serialized key and value byte
     * arrays. Once this sum exceeds the configured memory limit, no more update key values are
     * processed in the current transaction. When not everything is processed, the observer
     * processing updates will notify itself causing another transaction to continue processing
     * later
     */
    public FluentOptions bufferSize(long bufferSize);

    /**
     * Sets the number of buckets per tablet to generate. This affects how many split points will be
     * generated when optimizing the Accumulo table.
     */
    public FluentOptions bucketsPerTablet(int bucketsPerTablet);

    /**
     * Adds properties to the Fluo application configuration for this CombineQueue.
     */
    public void save(FluoConfiguration fluoConfig);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



modules/core/src/main/java/org/apache/fluo/recipes/core/export/ExportQueue.java [132:165]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  public static interface FluentArg3 {
    FluentOptions buckets(int numBuckets);
  }

  /**
   * Part of a fluent API for configuring a export queue.
   *
   * @since 1.1.0
   */
  public static interface FluentOptions {
    /**
     * Sets a limit on the amount of serialized updates to read into memory. Additional memory will
     * be used to actually deserialize and process the updates. This limit does not account for
     * object overhead in java, which can be significant.
     *
     * <p>
     * The way memory read is calculated is by summing the length of serialized key and value byte
     * arrays. Once this sum exceeds the configured memory limit, no more export key values are
     * processed in the current transaction. When not everything is processed, the observer
     * processing exports will notify itself causing another transaction to continue processing
     * later.
     */
    public FluentOptions bufferSize(long bufferSize);

    /**
     * Sets the number of buckets per tablet to generate. This affects how many split points will be
     * generated when optimizing the Accumulo table.
     */
    public FluentOptions bucketsPerTablet(int bucketsPerTablet);

    /**
     * Adds properties to the Fluo application configuration for this CombineQueue.
     */
    public void save(FluoConfiguration fluoConfig);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -