this.streamNum = streamNum;
}
@Override
public Object evaluate(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context) {
EventBean theEvent = eventsPerStream[streamNum];
if (theEvent == null) {
return null;
}
if (theEvent instanceof VariantEvent) {
return ((VariantEvent) theEvent).getUnderlyingEventBean().getEventType().getName();
}
return theEvent.getEventType().getName();
}