@@ -0,0 +1,1781 @@
+/*%0D%0A * Stratio Meta%0D%0A *%0D%0A *   Copyright (c) 2014, Stratio, All rights reserved.%0D%0A *%0D%0A *   This library is free software; you can redistribute it and/or modify it under the terms of the%0D%0A *   GNU Lesser General Public License as published by the Free Software Foundation; either version%0D%0A *   3.0 of the License, or (at your option) any later version.%0D%0A *%0D%0A *   This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without%0D%0A *   even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU%0D%0A *   Lesser General Public License for more details.%0D%0A *%0D%0A *   You should have received a copy of the GNU Lesser General Public License along with this library.%0D%0A */%0D%0A%0D%0Apackage com.stratio.connector.streaming.ftest.functionalMetadata;%0D%0A%0D%0Aimport com.stratio.connector.commons.ftest.functionalMetadata.GenericMetadataCreateTest;%0D%0Aimport com.stratio.connector.commons.ftest.helper.IConnectorHelper;%0D%0Aimport com.stratio.connector.streaming.ftest.helper.StreamingConnectorHelper;%0D%0Aimport com.stratio.meta.common.exceptions.ConnectionException;%0D%0Aimport com.stratio.meta.common.exceptions.InitializationException;%0D%0A%0D%0A/**%0D%0A * Created by jmgomez on 5/09/14.%0D%0A */%0D%0Apublic class StreamingCreateMetadataFunctionalTest extends GenericMetadataCreateTest %7B%0D%0A%0D%0A    @Override%0D%0A    protected IConnectorHelper getConnectorHelper() %7B%0D%0A    %09StreamingConnectorHelper esConnectorHelper = null;%0D%0A        try %7B%0D%0A            esConnectorHelper = new StreamingConnectorHelper(getClusterName());%0D%0A            return esConnectorHelper;%0D%0A        %7D catch (ConnectionException e) %7B%0D%0A            e.printStackTrace();%0D%0A        %7D catch (InitializationException e) %7B%0D%0A            e.printStackTrace();%0D%0A        %7D%0D%0A        return esConnectorHelper;%0D%0A    %7D%0D%0A%7D%0D%0A

add test