StreamOperationService extends StreamOperationServiceWithoutMetrics { @Override @Counted(absolute = true, name = "streams.total.altered", monotonic = true) public int enlargeStream(String streamName, List<ColumnNameTypeValue> columns) throws ServiceException { return super.enlargeStream(streamName, columns); } StreamOperationService(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao, CallbackService callbackService);  StreamOperationService(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao, CallbackService
        callbackService, DroolsConnectionContainer droolsConnectionContainer, ConfigurationContext configurationContext); @Override @Counted(absolute = true, name = "streams.total.created", monotonic = true) void createStream(String streamName, List<ColumnNameTypeValue> columns); @Override boolean streamExist(String streamName); @Override boolean isUserDefined(String streamName); @Override @Counted(absolute = true, name = "streams.total.altered", monotonic = true) int enlargeStream(String streamName, List<ColumnNameTypeValue> columns); @Override @Counted(absolute = true, name = "streams.total.deleted", monotonic = true) void dropStream(String streamName); @Override @Counted(absolute = true, name = "queries.total.added", monotonic = true) String addQuery(String streamName, String queryString); @Override @Counted(absolute = true, name = "queries.total.removed", monotonic = true) void removeQuery(String queryId, String streamName); @Override boolean queryIdExists(String streamName, String queryId); @Override boolean queryRawExists(String streamName, String queryRaw); @Override void enableAction(String streamName, StreamAction action); @Override void disableAction(String streamName, StreamAction action); @Override boolean isActionEnabled(String streamName, StreamAction action); @Override @Counted(absolute = true, name = "streams.total.listed", monotonic = true) List<StratioStreamingMessage> list(); @Override @Timed(absolute = true, name = "streams.send.time") void send(String streamName, List<ColumnNameTypeValue> columns); @Override void enableEngineAction(String streamName, EngineActionType engineActionType, Map<String, Object>
            engineActionParams);  }
@Test public void enlargeStreamTest() throws ServiceException { createBaseStream(); Assert.assertEquals("Expected value not found", 1, sm.getStreamDefinitions().size()); Assert.assertEquals("Expected value not found", 6, sm.getStreamDefinitions().get(0).getAttributeList().size()); List<ColumnNameTypeValue> columns = new ArrayList<>(); columns.add(new ColumnNameTypeValue("col7", ColumnType.INTEGER, null)); streamOperationService.enlargeStream(STREAM_NAME_GOOD, columns); Assert.assertEquals("Expected value not found", 1, sm.getStreamDefinitions().size()); Assert.assertEquals("Expected value not found", 7, sm.getStreamDefinitions().get(0).getAttributeList().size()); }