Skip navigation links


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

See: Description

Package 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()
Skip navigation links

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