org.springframework.data.hadoop.store.strategy.rollover

Class ChainedRolloverStrategy

java.lang.Object

org.springframework.data.hadoop.store.strategy.rollover.ChainedRolloverStrategy

All Implemented Interfaces:

RolloverStrategy, RolloverStrategyFactory<RolloverStrategy>

public class ChainedRolloverStrategy
extends java.lang.Object
implements RolloverStrategy

RolloverStrategy which is simply chaining other strategies.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
ChainedRolloverStrategy() Instantiates a new chained rollover strategy.
ChainedRolloverStrategy(java.util.List<? extends RolloverStrategy> strategies) Instantiates a new chained rollover strategy.

Method Summary

Methods

Modifier and Type	Method and Description
ChainedRolloverStrategy	createInstance() Creates a new instance of RolloverStrategy.
java.util.List<? extends RolloverStrategy>	getStrategies() Gets the strategies.
boolean	hasRolled() Checks if strategy wants to rollover.
void	register(RolloverStrategy strategy) Register a new strategy.
void	reset() Reset the strategy state.
void	setStrategies(java.util.List<? extends RolloverStrategy> strategies) Sets the list of strategies.
void	setWritePosition(long position) Sets the write position.

Methods inherited from class java.lang.Object

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

Constructor Detail

ChainedRolloverStrategy

public ChainedRolloverStrategy()

Instantiates a new chained rollover strategy.

ChainedRolloverStrategy

public ChainedRolloverStrategy(java.util.List<? extends RolloverStrategy> strategies)

Instantiates a new chained rollover strategy.

Parameters:

strategies - the strategies

Method Detail

hasRolled

public boolean hasRolled()

Description copied from interface: RolloverStrategy

Checks if strategy wants to rollover.

Specified by:

hasRolled in interface RolloverStrategy

Returns:

true, if rollover should happen

reset

public void reset()

Description copied from interface: RolloverStrategy

Reset the strategy state.

Specified by:

reset in interface RolloverStrategy

setWritePosition

public void setWritePosition(long position)

Description copied from interface: RolloverStrategy

Sets the write position.

Specified by:

setWritePosition in interface RolloverStrategy

Parameters:

position - the new write position

createInstance

public ChainedRolloverStrategy createInstance()

Description copied from interface: RolloverStrategyFactory

Creates a new instance of RolloverStrategy.

Specified by:

createInstance in interface RolloverStrategyFactory<RolloverStrategy>

Returns:

a new instance of rollover strategy

setStrategies

public void setStrategies(java.util.List<? extends RolloverStrategy> strategies)

Sets the list of strategies. This clears all existing strategies.

Parameters:

strategies - the new strategies

register

public void register(RolloverStrategy strategy)

Register a new strategy.

Parameters:

strategy - the strategy

getStrategies

public java.util.List<? extends RolloverStrategy> getStrategies()

Gets the strategies.

Returns:

the strategies