@Test public void testEnlargeStream() throws Exception { streamOperationsService.createInternalStream(StreamsHelper.STREAM_NAME, StreamsHelper.COLUMNS); streamOperationsService.enlargeStream(StreamsHelper.STREAM_NAME, new LinkedList<ColumnNameTypeValue>() { { add(new ColumnNameTypeValue("additionalColumn", ColumnType.STRING, "additionalColumn")); } }); assertTrue("Expected true not found", streamOperationsService.streamExist(StreamsHelper.STREAM_NAME)); }
public int enlargeStream(String streamName, List<ColumnNameTypeValue> columns) throws ServiceException { return enlargeStream(streamName, columns, true); }
StreamOperationServiceWithoutMetrics { public int enlargeStream(String streamName, List<ColumnNameTypeValue> columns) throws ServiceException { return enlargeStream(streamName, columns, true); } }
StreamOperationServiceWithoutMetrics { public int enlargeStream(String streamName, List<ColumnNameTypeValue> columns) throws ServiceException { return enlargeStream(streamName, columns, true); } StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
                                                CallbackService callbackService);  StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
            CallbackService callbackService, ConfigurationContext configurationContext);  StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
        CallbackService callbackService, DroolsConnectionContainer droolsConnectionContainer, ConfigurationContext configurationContext); }
StreamOperationServiceWithoutMetrics { public int enlargeStream(String streamName, List<ColumnNameTypeValue> columns) throws ServiceException { return enlargeStream(streamName, columns, true); } StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
                                                CallbackService callbackService);  StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
            CallbackService callbackService, ConfigurationContext configurationContext);  StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
        CallbackService callbackService, DroolsConnectionContainer droolsConnectionContainer, ConfigurationContext configurationContext); void createInternalStream(String streamName, List<ColumnNameTypeValue> columns); void createStream(String streamName, List<ColumnNameTypeValue> columns); boolean streamExist(String streamName); boolean isUserDefined(String streamName); int enlargeStream(String streamName, List<ColumnNameTypeValue> columns); int enlargeStream(String streamName, List<ColumnNameTypeValue> columns, Boolean raiseException); void dropStream(String streamName); String addQuery(String streamName, String queryString); void removeQuery(String queryId, String streamName); boolean queryIdExists(String streamName, String queryId); boolean queryRawExists(String streamName, String queryRaw); Boolean columnExists(String streamName, String columnName); void enableAction(String streamName, StreamAction action); void disableAction(String streamName, StreamAction action); boolean isActionEnabled(String streamName, StreamAction action); void enableEngineAction(String streamName, EngineActionType engineActionType, Map<String, Object>
            engineActionParams); void disableEngineAction(String streamName, EngineActionType engineActionType); List<StratioStreamingMessage> list(); void send(String streamName, List<ColumnNameTypeValue> columns); }
StreamOperationServiceWithoutMetrics { public int enlargeStream(String streamName, List<ColumnNameTypeValue> columns) throws ServiceException { return enlargeStream(streamName, columns, true); } StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
                                                CallbackService callbackService);  StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
            CallbackService callbackService, ConfigurationContext configurationContext);  StreamOperationServiceWithoutMetrics(SiddhiManager siddhiManager, StreamStatusDao streamStatusDao,
        CallbackService callbackService, DroolsConnectionContainer droolsConnectionContainer, ConfigurationContext configurationContext); void createInternalStream(String streamName, List<ColumnNameTypeValue> columns); void createStream(String streamName, List<ColumnNameTypeValue> columns); boolean streamExist(String streamName); boolean isUserDefined(String streamName); int enlargeStream(String streamName, List<ColumnNameTypeValue> columns); int enlargeStream(String streamName, List<ColumnNameTypeValue> columns, Boolean raiseException); void dropStream(String streamName); String addQuery(String streamName, String queryString); void removeQuery(String queryId, String streamName); boolean queryIdExists(String streamName, String queryId); boolean queryRawExists(String streamName, String queryRaw); Boolean columnExists(String streamName, String columnName); void enableAction(String streamName, StreamAction action); void disableAction(String streamName, StreamAction action); boolean isActionEnabled(String streamName, StreamAction action); void enableEngineAction(String streamName, EngineActionType engineActionType, Map<String, Object>
            engineActionParams); void disableEngineAction(String streamName, EngineActionType engineActionType); List<StratioStreamingMessage> list(); void send(String streamName, List<ColumnNameTypeValue> columns);  }