stream-processing-windowing-designer

# Stream Processing Windowing Designer ## Overview Designs optimal windowing strategies for stream processing. This skill provides expertise in window types, watermarks, and trigger strategies for streaming applications. ## Capabilities - Window type selection (tumbling, sliding, session, global) - Watermark strategy design - Late data handling - Trigger configuration - Window aggregation optimization - State management recommendations - Exactly-once semantics configuration ## Input Schema ```json { "useCase": "string", "eventTimeField": "string", "latencyRequirements": { "maxLatencyMs": "number", "allowedLateMs": "number" }, "aggregations": ["object"] } ``` ## Output Schema ```json { "windowConfig": { "type": "string", "size": "string", "slide": "string" }, "watermarkConfig": "object", "triggerConfig": "object", "lateDataHandling": "object" } ``` ## Target Processes - Streaming Pipeline - Feature Store Setup ## Usage Guidelines 1. Define use case and event time field 2. Specify latency requirements 3. List aggregation operations needed 4. Consider late data arrival patterns ## Best Practices - Choose window type based on business requirements - Configure watermarks based on expected lateness - Use appropriate triggers for latency vs completeness tradeoff - Plan state management for long windows - Test with realistic event time distributions