}
public BehaviorExpireWMAction(MarshallerReaderContext context,
Action _action) {
int sinkId =_action.getBehaviorExpire().getNodeId();
BetaNode betaNode = (BetaNode) context.sinks.get( sinkId );
BetaMemory betaMemory = null;
if ( betaNode instanceof AccumulateNode ) {
betaMemory = (( AccumulateMemory ) context.wm.getNodeMemory( betaNode )).betaMemory;
} else {
betaMemory = ( BetaMemory ) context.wm.getNodeMemory( betaNode );
}
Object[] behaviorContext = ( Object[] ) betaMemory.getBehaviorContext();
int i = 0; // <==== this needs fixing
this.behavior = (SlidingTimeWindow) betaNode.getBehaviors()[i];
this.context = ( SlidingTimeWindowContext ) behaviorContext[i];
}