org.springframework.xd.integration.hadoop.partition

Class MessagePartitionStrategy<T>

java.lang.Object

org.springframework.data.hadoop.store.partition.AbstractPartitionStrategy<T,org.springframework.messaging.Message<?>>

org.springframework.xd.integration.hadoop.partition.MessagePartitionStrategy<T>

All Implemented Interfaces:

org.springframework.data.hadoop.store.partition.PartitionStrategy<T,org.springframework.messaging.Message<?>>

public class MessagePartitionStrategy<T>
extends org.springframework.data.hadoop.store.partition.AbstractPartitionStrategy<T,org.springframework.messaging.Message<?>>

A PartitionStrategy which is used to provide a generic partitioning support using Spring SpEL.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
MessagePartitionStrategy(org.springframework.expression.Expression expression, org.springframework.expression.spel.support.StandardEvaluationContext evaluationContext) Instantiates a new message partition strategy with EvaluationContext.
MessagePartitionStrategy(java.lang.String expression, org.springframework.expression.spel.support.StandardEvaluationContext evaluationContext) Instantiates a new message partition strategy with EvaluationContext.
MessagePartitionStrategy(java.lang.String expression, org.springframework.expression.spel.support.StandardEvaluationContext evaluationContext, org.springframework.expression.ExpressionParser expressionParser) Instantiates a new message partition strategy with EvaluationContext.

Method Summary

Methods inherited from class org.springframework.data.hadoop.store.partition.AbstractPartitionStrategy

getPartitionKeyResolver, getPartitionResolver

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessagePartitionStrategy

public MessagePartitionStrategy(org.springframework.expression.Expression expression,
                        org.springframework.expression.spel.support.StandardEvaluationContext evaluationContext)

Instantiates a new message partition strategy with EvaluationContext.

Parameters:

expression - the expression

evaluationContext - the evaluation context

MessagePartitionStrategy

public MessagePartitionStrategy(java.lang.String expression,
                        org.springframework.expression.spel.support.StandardEvaluationContext evaluationContext)

Instantiates a new message partition strategy with EvaluationContext.

Parameters:

expression - the expression

evaluationContext - the evaluation context

MessagePartitionStrategy

public MessagePartitionStrategy(java.lang.String expression,
                        org.springframework.expression.spel.support.StandardEvaluationContext evaluationContext,
                        org.springframework.expression.ExpressionParser expressionParser)

Instantiates a new message partition strategy with EvaluationContext.

Parameters:

expression - the expression

evaluationContext - the evaluation context

expressionParser - the expression parser