Window properties - Cloud

Talend Cloud Pipeline Designer Processors Guide

author
Talend Documentation Team
EnrichVersion
Cloud
EnrichProdName
Talend Cloud
task
Design and Development > Designing Pipelines
EnrichPlatform
Talend Pipeline Designer

Properties to divide your streaming data into micro-batches based on time intervals using the Window processor.

The Window processor should always be followed by an Aggregate processor.

Property

Configuration

Name

Enter a display name for the Window processor.

Description (optional)

Enter a description for the Window processor.

Window duration (ms)

Enter the time in milliseconds during which you want to capture the streaming data.

Sliding duration (ms)

Enter the time in milliseconds elapsed between the closure of a window and the opening of a new one.

Use Window session

If you activate this toggle, the Sliding duration property disappears as the sizes of these windows are unpredictable and the window gap duration becomes a minimal gap duration.

It means that data will be stored in memory as long as it comes in, and when it pauses micro-batches are sent in output as a new window starts.