@Test(dependsOnMethods = {"testQueryAbsent42"})
    public void testQueryAbsent43() throws InterruptedException {
        log.info("Test the partitioned query e1 -> not e2 for 1 sec");

        SiddhiManager siddhiManager = new SiddhiManager();

        String streams = "" +
                "define stream CustomerStream (customerId string); ";
        String query = "" +
                "partition with (customerId of CustomerStream) " +
                "begin " +
                "from e1=CustomerStream -> not CustomerStream[customerId == e1.customerId] for 1 sec " +
                "select e1.customerId " +
                "insert into OutputStream; " +
                "end ";

        SiddhiAppRuntime siddhiAppRuntime = siddhiManager.createSiddhiAppRuntime(streams + query);

        TestUtil.TestCallback callback = TestUtil.addStreamCallback(siddhiAppRuntime, "OutputStream", new
                Object[]{"customerA"});

        InputHandler customerStream = siddhiAppRuntime.getInputHandler("CustomerStream");

        siddhiAppRuntime.start();

        customerStream.send(new Object[]{"customerA"});
        customerStream.send(new Object[]{"customerB"});
        Thread.sleep(500);
        customerStream.send(new Object[]{"customerB"});

        TestUtil.waitForInEvents(500, callback, 5);
        callback.throwAssertionErrors();
        AssertJUnit.assertEquals("Number of success events", 1, callback.getInEventCount());
        AssertJUnit.assertTrue("Event not arrived", callback.isEventArrived());

        siddhiAppRuntime.shutdown();
    }
Test the patterns:
- A -> not B for 1 sec
- not A for 1 sec -> B
modules/siddhi-core/src/test/java/io/siddhi/core/query/pattern/absent/AbsentPatternTestCase.java