Overview of the Streaming Web API
The platform’s Streaming Web API enables working with data in the platform as streams. For more information, see the Streams overview.
To create and configure a new stream, use
To get the description of a stream’s configuration, use
To update a stream’s configuration (change its shard count), use
To add records to a stream, use
You can optionally control the assignment of records to specific shards. For more information, see Stream Sharding and Partitioning.
To retrieve a specific location within a shard, to be used in a subsequent
GetRecordsoperation, use Seek.
To retrieve records from a specific stream shard, use
GetRecords. GetRecordsreceives as a parameter the location within the specified stream shard from which to begin consuming records. Use the Seekoperation to retrieve the location of the first record to consume, according to the desired location type. GetRecordsreturns the location of the next record in the shard to consume, which you can use as the location parameter of a subsequent GetRecordsoperation. For more information, see Stream Record Consumption.
To delete a stream, either delete (remove) the stream directory by using a file-system command, or use the
deleteclient method of the V3IO Frames streaming backend. See Deleting Streams.
The Streaming Web API is part of the data-service web APIs and conforms to the related structure and syntax rules — see Data-Service Web-API General Structure.