public interface PartitionStrategyConfigurer extends org.springframework.data.hadoop.config.common.annotation.AnnotationConfigurerBuilder<DataStoreTextWriterConfigurer>
AnnotationConfigurerBuilder for configuring a partition strategy.
Typically configuration is shown below.
@Configuration
@EnableDataStoreTextWriter
static class Config extends SpringDataStoreTextWriterConfigurerAdapter {
@Override
public void configure(DataStoreTextWriterConfigurer writer) throws Exception {
writer
.withPartitionStrategy()
.map("myspel");
}
}
| Modifier and Type | Method and Description |
|---|---|
PartitionStrategyConfigurer |
custom(PartitionStrategy<?,?> partitionStrategy)
Specify a custom
PartitionStrategy. |
PartitionStrategyConfigurer |
map(String expression)
Specify to use
DefaultPartitionStrategy with a given
SpEL expression. |
PartitionStrategyConfigurer custom(PartitionStrategy<?,?> partitionStrategy)
PartitionStrategy.
public void configure(DataStoreTextWriterConfigurer writer) throws Exception {
writer
.withPartitionStrategy()
.custom(new MyCustomPartitionStrategy());
}
partitionStrategy - the partition strategyPartitionStrategyConfigurer for chainingPartitionStrategyConfigurer map(String expression)
DefaultPartitionStrategy with a given
SpEL expression.
public void configure(DataStoreTextWriterConfigurer writer) throws Exception {
writer
.withPartitionStrategy()
.map("spelexpression");
}
expression - the partition expressionPartitionStrategyConfigurer for chaining