public class DefaultPartitionStrategyConfigurer extends org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurerAdapter<SpringDataStoreWriterConfigs,DataStoreTextWriterConfigurer,DataStoreTextWriterBuilder> implements PartitionStrategyConfigurer
AnnotationConfigurer which knows howto configure a partition strategy.| Constructor and Description |
|---|
DefaultPartitionStrategyConfigurer() |
| Modifier and Type | Method and Description |
|---|---|
void |
configure(DataStoreTextWriterBuilder builder) |
PartitionStrategyConfigurer |
custom(PartitionStrategy<?,?> partitionStrategy)
Specify a custom
PartitionStrategy. |
PartitionStrategyConfigurer |
map(String expression)
Specify to use
DefaultPartitionStrategy with a given
SpEL expression. |
addObjectPostProcessor, and, getBuilder, init, isAssignable, setBuilderpublic void configure(DataStoreTextWriterBuilder builder) throws Exception
configure in interface org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurer<SpringDataStoreWriterConfigs,DataStoreTextWriterBuilder>configure in class org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurerAdapter<SpringDataStoreWriterConfigs,DataStoreTextWriterConfigurer,DataStoreTextWriterBuilder>Exceptionpublic PartitionStrategyConfigurer custom(PartitionStrategy<?,?> partitionStrategy)
PartitionStrategyConfigurerPartitionStrategy.
public void configure(DataStoreTextWriterConfigurer writer) throws Exception {
writer
.withPartitionStrategy()
.custom(new MyCustomPartitionStrategy());
}
custom in interface PartitionStrategyConfigurerpartitionStrategy - the partition strategyPartitionStrategyConfigurer for chainingpublic PartitionStrategyConfigurer map(String expression)
PartitionStrategyConfigurerDefaultPartitionStrategy with a given
SpEL expression.
public void configure(DataStoreTextWriterConfigurer writer) throws Exception {
writer
.withPartitionStrategy()
.map("spelexpression");
}
map in interface PartitionStrategyConfigurerexpression - the partition expressionPartitionStrategyConfigurer for chaining