@@ -0,0 +1,2468 @@
+package bluemix;%0A%0Aimport java.io.File;%0Aimport java.math.BigInteger;%0Aimport java.util.HashMap;%0Aimport java.util.Map;%0A%0Aimport com.ibm.streamsx.topology.TStream;%0Aimport com.ibm.streamsx.topology.Topology;%0Aimport com.ibm.streamsx.topology.context.AnalyticsServiceProperties;%0Aimport com.ibm.streamsx.topology.context.JobProperties;%0Aimport com.ibm.streamsx.topology.context.StreamsContext;%0Aimport com.ibm.streamsx.topology.context.StreamsContext.Type;%0Aimport com.ibm.streamsx.topology.context.StreamsContextFactory;%0A%0A/**%0A * Sample demonstrating submission of a topology%0A * to Streaming Analytic Service on Bluemix. %0A *%0A */%0Apublic class Submit2StreamingAnalyticService %7B%0A    %0A    public static void main(String%5B%5D args) throws Exception %7B%0A        %0A        String vcapFile = args%5B0%5D;%0A        String serviceName = args%5B1%5D;%0A%0A        /*%0A         * Create a simple topology, focus of the%0A         * sample is the submission of the job%0A         * to the service.%0A         * %0A         * This topology is just like simple.HelloWorld%0A         * with different values printed to the console log.%0A         */%0A        Topology topology = new Topology(%22Submit2StreamingAnalyticService%22);%0A        topology.strings(%0A                %22Hello%22, %22Streaming Analytic Service%22,%0A                serviceName, %22running on IBM Bluemix%22).print();       %0A        %0A        // Require a configuration object.%0A        Map%3CString,Object%3E config = new HashMap%3C%3E();%0A        %0A        // Here the VCAP_SERVICES information is in a local file%0A        // (as serialized JSON)%0A        config.put(AnalyticsServiceProperties.VCAP_SERVICES, new File(vcapFile));%0A        %0A        // Explicitly state which service is the job will be submitted to%0A        // The service must be in the Streaming Analytic Service section%0A        // of the VCAP services.%0A        config.put(AnalyticsServiceProperties.SERVICE_NAME, serviceName);%0A        %0A        // Optionally we can specify a job name%0A        // (note job names must be unique within the instance).%0A        config.put(JobProperties.NAME, %22BluemixSubmitSample%22);%0A        %0A        // Submit to the ANALYICS_SERVICE context%0A        @SuppressWarnings(%22unchecked%22)%0A        StreamsContext%3CBigInteger%3E context =%0A             (StreamsContext%3CBigInteger%3E) StreamsContextFactory.getStreamsContext(Type.ANALYTICS_SERVICE);%0A        %0A        BigInteger jobId = context.submit(topology, config).get();%0A%0A        System.out.println(%22Submitted job with jobId=%22 + jobId);%0A        %0A    %7D%0A%7D%0A

Add sample for submission to bluemix