Slider implements Unifier<Object>, Operator.IdleTimeHandler, Operator.ActivationListener<OperatorContext>, StatsListener, Serializable, Operator.CheckpointListener { private Slider() { unifier = null; numberOfBuckets = -1; numberOfSlideBuckets = -1; } private  Slider();  Slider(Unifier<Object> uniOperator, int buckets, int numberOfSlideBuckets); Unifier<Object> getUnifier(); @Override void process(Object tuple); @Override void beginWindow(long windowId); @Override void endWindow(); @Override void setup(OperatorContext context); @Override void teardown(); @Override @SuppressWarnings("unchecked") void activate(OperatorContext context); @Override void deactivate(); @Override void handleIdleTime(); @Override Response processStats(BatchedOperatorStats stats); @Override void checkpointed(long windowId); @Override void committed(long windowId); final transient DefaultOutputPort<Object> outputPort; }
@Test public void testSlider() throws Exception { test(5, 1); }