Skip navigation links

Package co.cask.cdap.api.data.stream

Deprecated.
As of release 5.0.0, use Kafka as a replacement technology for Streams
Stream specification and configuration.

See: Description

Package co.cask.cdap.api.data.stream Description

Stream specification and configuration. Streams are used for bringing data from external systems into CDAP. Streams are identified by a string and must be explicitly created before being used. Streams are used along with datasets and flows to create applications. For example:
     public MyApplication extends AbstractApplication {
       public void configure() {
         MyDataSet myDataset = new MyDataset("my");
         TimeseriesDataSet timeseriesDataset = new TimeseriesDataSet("mytimeseries");
         Stream clickStream = new Stream("mystream");
         return new ApplicationSpecification.Builder()
            .addDataSet(myDataset)
            .addDataSet(timeseriesDataset);
            .addStream(clickStream)
            .addFlow(ClickProcessingFlow.class)
            .create();
       }
     }
   
Skip navigation links

Copyright © 2018 Cask Data, Inc.. All rights reserved.