@Test public void testCreateInstance() throws Exception { WindowCreator creater = new TimeBatchWindowCreator(); creater.createInstance(createWindow(), initSchema(), null); assertTrue(true); }
@Override public IWindow createInstance(Window window, List<Schema> schemas, Map<String, String> systemConfig) throws ExecutorException { return new TimeBatchWindow(window.getLength()); }
TimeBatchWindowCreator implements WindowCreator { @Override public IWindow createInstance(Window window, List<Schema> schemas, Map<String, String> systemConfig) throws ExecutorException { return new TimeBatchWindow(window.getLength()); } }
TimeBatchWindowCreator implements WindowCreator { @Override public IWindow createInstance(Window window, List<Schema> schemas, Map<String, String> systemConfig) throws ExecutorException { return new TimeBatchWindow(window.getLength()); }  }
TimeBatchWindowCreator implements WindowCreator { @Override public IWindow createInstance(Window window, List<Schema> schemas, Map<String, String> systemConfig) throws ExecutorException { return new TimeBatchWindow(window.getLength()); }  @Override IWindow createInstance(Window window, List<Schema> schemas, Map<String, String> systemConfig); }
TimeBatchWindowCreator implements WindowCreator { @Override public IWindow createInstance(Window window, List<Schema> schemas, Map<String, String> systemConfig) throws ExecutorException { return new TimeBatchWindow(window.getLength()); }  @Override IWindow createInstance(Window window, List<Schema> schemas, Map<String, String> systemConfig);  }