@Override
    public void describe(TaskApplicationDescriptor appDescriptor) {
      DelegatingSystemDescriptor ksd = new DelegatingSystemDescriptor(SYSTEM_NAME);
      GenericInputDescriptor<TestTableData.PageView> pageViewIsd = ksd.getInputDescriptor(STREAM_ID, new NoOpSerde<>());
      appDescriptor
          .withInputStream(pageViewIsd)
          .withTaskFactory((StreamTaskFactory) PageViewEventCountStreamTask::new);
    }
End to end integration test to check drain functionality with samza low-level API.
Tests have been annotated with @Ignore as they seem to timeout on the build system.
samza-test/src/test/java/org/apache/samza/test/drain/DrainLowLevelApiIntegrationTest.java