Statements (60)
| Predicate | Object |
|---|---|
| gptkbp:instanceOf |
Data Processing Paradigm
|
| gptkbp:alsoKnownAs |
gptkb:Stream_Processing
|
| gptkbp:challenge |
Scalability
Fault Tolerance Latency Optimization State Management Data Consistency Backpressure Handling Event Time vs Processing Time Handling Out-of-order Events Windowing Semantics |
| gptkbp:characteristic |
Scalability
Fault Tolerance Low Latency Event Time Processing High Throughput At-least-once Semantics Exactly-once Semantics In-order Processing Windowing Stateful Processing |
| gptkbp:commonFramework |
gptkb:Apache_Kafka
gptkb:Amazon_Kinesis gptkb:Apache_Flink gptkb:Apache_Storm gptkb:Google_Dataflow gptkb:Samza gptkb:Microsoft_Azure_Stream_Analytics gptkb:Apache_Spark_Streaming Heron |
| gptkbp:contrastsWith |
Batch Data Processing
|
| gptkbp:enables |
Dynamic Scaling
Real-time Decision Making Immediate Feedback Continuous Data Ingestion Time-sensitive Applications |
| https://www.w3.org/2000/01/rdf-schema#label |
Streaming Data Processing
|
| gptkbp:input |
Continuous Data Streams
|
| gptkbp:output |
Alerts
Dashboards Aggregated Results Processed Streams |
| gptkbp:relatedConcept |
gptkb:Complex_Event_Processing
Message Queues Data Pipelines Kappa Architecture Lambda Architecture Publish-Subscribe Systems |
| gptkbp:usedFor |
gptkb:IoT_Applications
Monitoring Recommendation Systems Fraud Detection Log Analysis Real-time Analytics Continuous Computation Event Detection Financial Market Analysis Sensor Data Processing |
| gptkbp:bfsParent |
gptkb:Databricks_Data_Transformation
|
| gptkbp:bfsLayer |
8
|