Statements (59)
| Predicate | Object |
|---|---|
| gptkbp:instance_of |
gptkb:drug
|
| gptkbp:bfsLayer |
3
|
| gptkbp:bfsParent |
gptkb:drug
|
| gptkbp:can_be |
Flink jobs
|
| gptkbp:communication |
gptkb:Flink_Job_Manager
|
| gptkbp:controls |
Multiple jobs
|
| gptkbp:deployment |
gptkb:fortification
gptkb:YARN Cloud environments On-premises environments Standalone cluster |
| gptkbp:handles |
State management
|
| https://www.w3.org/2000/01/rdf-schema#label |
Flink Task Manager
|
| gptkbp:integrates_with |
External systems
|
| gptkbp:is_available_on |
Automatically
Manually |
| gptkbp:is_compatible_with |
Flink versions
|
| gptkbp:is_optimized_for |
Low-latency processing
High-throughput processing |
| gptkbp:is_part_of |
Distributed system
Flink architecture Flink ecosystem Flink runtime |
| gptkbp:is_scalable |
gptkb:theorem
|
| gptkbp:is_used_for |
Data transformation
Data enrichment Data ingestion Data output State backends |
| gptkbp:is_used_in |
Real-time analytics
Batch data processing Data streaming applications |
| gptkbp:managed_by |
gptkb:Flink_Job_Manager
Web UI Flink CLI |
| gptkbp:manages |
Task slots
|
| gptkbp:monitors |
Task execution
|
| gptkbp:part_of |
gptkb:drug
|
| gptkbp:passes_through |
Cluster nodes
|
| gptkbp:provides |
Resource management
Metrics reporting |
| gptkbp:responsible_for |
Checkpointing
Fault tolerance Executing tasks |
| gptkbp:scales |
Horizontally
Vertically Dynamically |
| gptkbp:setting |
CPU settings
Network settings Checkpoint interval Logging settings Memory settings State TTL Task slot configuration |
| gptkbp:supports |
Stream processing
Batch processing Watermarking Event time processing |
| gptkbp:written_in |
gptkb:Java
|