List of Streaming Integrator Samples¶
Consume¶
- Recieve TCP in JSON Format
- Publish Google PubSub Messages In Text Format
- CSV Default Mapping
- CDC With Listening Mode
- Receive Google PubSub Messages In Text Format
- Receive MQTT In XML Format
- Receive TCP in Binary Format
- Receive Kafka In Binary Format
- Receive HTTP In XML Format With Default Mapping
- CDC With Polling Mode
- Twitter Polling sample
- Publish Http OAuth Request With Refresh Token
- Publish Http OAuth Request Response
- Store solr
- Receive WSO2 Events
- Receive Events From File
- Receive Email In Xml Format
- Receive Rabbitmq In JSON Format
- Store cassandra
Transform¶
- Publish Http OAuth Request
- Publish Http OAuth Request Without Access Token
- Receive Hl7 In ER7 Format
- Data Preprocessing
- Publish Hl7 In ER7 Format
- Sweet Production Data Pre-processing
- CSV Custom Mapping
- Publish HTTP In Json Format With Custom Mapping
- Publish Email In Text Format
- Receive Kafka In Text Format With Custom Mapping
- Script js sample
- Publish Kafka In Custom Avro Format
- Receive Hl7 In Xml Format
- Regex Execution Sample
- Kalman Filter Execution Sample
- Publish Hl7 In Xml Format
- Publish Kafka In Json Format
- Publish Events To File
- Receive HTTP in XML Format With Custom Mapping
- Publish Rabbitmq In Xml Format
- Math Extension Sample
- Receive TCP in Text Format
- Publish Email In Xml Format
- Time Series Extension Sample
- Twitter Streaming sample
- String Extension Sample
- Text Mapping With In memory Transport
- Receive HTTP In Json Format With Default Mapping
- Hello Kafka
- Publish Http In Xml Format With Custom Mapping
- SNMP Set Request App
- Publish Tcp In Json Format
- Publish Http OAuth Request With OAuth User
- Map Extension Sample
- Publish Jms In Xml Format
- Receive JMS In Json Format
- Receive HTTP In Json Format With Custom Mapping
Publish¶
- Publish Tcp In Text Format
- Receive Hl7 In ER7 Format
- Publish Google PubSub Messages In Text Format
- Publish Tcp In Binary Format
- Publish Web Socket In Xml Format
- Publish Prometheus Metrics HTTP Server
- store influxdb
- Publish Kafka In BinaryFormat
- Publish Jms In Key value Format
- Http Request Response Sample
- Publish WSO2 Events
- Publish Http In Xml Format
- Publish Http OAuth Request With Refresh Token
- Publish Http OAuth Request Response
- Store solr
- Publish Http In Json Format
- Store rdbms
- Store cassandra
- Publish Kafka In Avro Format Using Schema Registry
Insights¶
- Pmml Model Processor
- Streaming Regressor
- Gpl NLP Find Name Entity Type
- Tensor Flow TestApp
- Markov Chain Sample
- Priority Extension Sample
- approximate distinctCountEver sample
- approximate distinctCount sample
- sentiment Extension Sample
- Pattern Matching
- Streaming KMeans Sample
- R Script Sample
- Receive Prometheus Metrics
- hoeffding adaptive tree sample
- Alerts And Thresholds
- streaming perceptron sample
- Geo Distance Calculation
Aggregate¶
- Data Preprocessing
- Aggregate Over Time
- approximate distinctCountEver sample
- approximate distinctCount sample
- Receive And Count
- Aggregate Data Incrementally
- Store redis
- approximate count sample
- store mongodb
Enrich¶
- Extrema Bottom K
- Gpl NLP Find Name Entity Type
- Join With Stored Data
- Script js sample
- store hbase
- Unit Conversion Extention Sample
- sentiment Extension Sample
- execution geo sample
- Clus Tree Test App
- Receive WebSocket In XML Format