public class DefaultRolloverStrategyConfigurer extends org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurerAdapter<BeanDefinition,DataStoreTextWriterConfigurer,DataStoreTextWriterBuilder> implements RolloverStrategyConfigurer
AnnotationConfigurer which knows howto configure a rollover strategy.| Constructor and Description |
|---|
DefaultRolloverStrategyConfigurer() |
| Modifier and Type | Method and Description |
|---|---|
void |
configure(DataStoreTextWriterBuilder builder) |
RolloverStrategyConfigurer |
size(long size)
Specify a rollover size in bytes.
|
RolloverStrategyConfigurer |
size(String size)
Specify a rollover size.
|
addObjectPostProcessor, and, getBuilder, init, isAssignable, setBuilderpublic void configure(DataStoreTextWriterBuilder builder) throws Exception
configure in interface org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurer<BeanDefinition,DataStoreTextWriterBuilder>configure in class org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurerAdapter<BeanDefinition,DataStoreTextWriterConfigurer,DataStoreTextWriterBuilder>Exceptionpublic RolloverStrategyConfigurer size(long size)
RolloverStrategyConfigurer
public void configure(DataStoreTextWriterConfigurer writer) throws Exception {
writer
.withRolloverStrategy()
.size(10000);
}
size in interface RolloverStrategyConfigurersize - the sizeRolloverStrategyConfigurer for chainingpublic RolloverStrategyConfigurer size(String size)
RolloverStrategyConfigurer
public void configure(DataStoreTextWriterConfigurer writer) throws Exception {
writer
.withRolloverStrategy()
.size("1M");
}
size in interface RolloverStrategyConfigurersize - the sizeRolloverStrategyConfigurer for chaining