public static interface ExportQueue.FluentOptions
Modifier and Type | Method and Description |
---|---|
ExportQueue.FluentOptions |
bucketsPerTablet(int bucketsPerTablet)
Sets the number of buckets per tablet to generate.
|
ExportQueue.FluentOptions |
bufferSize(long bufferSize)
Sets a limit on the amount of serialized updates to read into memory.
|
void |
save(org.apache.fluo.api.config.FluoConfiguration fluoConfig)
Adds properties to the Fluo application configuration for this CombineQueue.
|
ExportQueue.FluentOptions bufferSize(long bufferSize)
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.
ExportQueue.FluentOptions bucketsPerTablet(int bucketsPerTablet)
void save(org.apache.fluo.api.config.FluoConfiguration fluoConfig)
Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.