### Question:
DecisionMetadataEngine extends CommonsMetadataEngine<IStratioStreamingAPI> { @Override @TimerJ protected void dropTable(TableName stream, Connection<IStratioStreamingAPI> connection) throws ExecutionException, UnsupportedException { String streamName = StreamUtil.createStreamName(stream); try { connection.getNativeConnection().dropStream(streamName); } catch (StratioStreamingException e) { String msg = "Fail dropping the Stream [" + streamName + "]. " + e.getMessage(); logger.error(msg); throw new ExecutionException(msg, e); } } DecisionMetadataEngine(ConnectionHandler connectionHandler);   }### Answer:
@Test public void dropTableTest() throws Exception { decisionMetadataEngine.dropTable(new TableName(CATALOG, TABLE), connection); verify(decisionApi, times(1)).dropStream(CATALOG + "_" + TABLE); }