Last Updated on : 2024-06-20 06:42:24download
With our development platform, you can create your tasks through drag-and-drop components.
The platform provides a directed acyclic graph (DAG) consisting of components and data flow.
Components indicate the processing of data. Several components are preset on the platform.
Data flow is the data transfer between components. The data flow has specified fields and formats. On the canvas, the connecting line between components represents the data flow.
The components are categorized into three types, input components, conversion components, and output components. You must select at least one input component, one conversion component, and one output component for the task.
For unconfigured components, an exclamation point will show in the top-right corner.
Function
Select a product data source for data processing.
Basic Configuration
report
is supported.Output Parameter
The input component only has output parameters, indicating the output fields of the component.
Function
Select a data source from cloud projects for data processing.
Basic Configuration
report
is supported.Output Parameter
The input component only has output parameters, indicating the output fields of the component.
Function
Filter the data by setting conditions. You can add several conditions linked by logical operators AND
or OR
. If you want to filter data as per the field value of a single item of data, you can select this component.
Basic Configuration
AND
or Or
. AND
: Satisfy all the following conditions. OR
: Satisfy one of the following conditions.Input Parameter
The fields and data types output by the previous component.
Output Parameter
The fields and data types processed by the component. The data field processed by the output component is consistent with the input parameter.
Function
Aggregate multiple items of data to process them. Algorithms of SUM, AVERAGE, MAX, MIN, and COUNT are supported.
Basic Configuration
Input Parameter
The fields and data types output by the previous component.
Output Parameter
The fields and data types processed by the component. The fields of statistical dimensions, time, aggregation are kept.
Description of the time window
Tumbling window: Tuples are grouped in a single window based on time or count. A tuple belongs to only one window. The tumbling window is evaluated at a specified interval, and none of the windows overlap. For example, consider a time-based tumbling window with a length of 5 minutes. Data of infinite flow will be divided into [0:00, 0:05)
, [0:05, 0:10)
, [0:10, 0:15)
as per the time duration. The image below shows a tumbling window of 30 seconds.
Sliding window: Unlike the tumbling window, the window can overlap. Sliding windows can contain overlapping data, and an event can belong to more than one sliding window. So it is useful for working out moving averages. The image below shows a sliding window of 1 minute, at a time interval of 30 seconds.
Function
Select one or more fields. You can change the data type of the selected fields.
Basic Configuration
Input Parameter
The fields and data types output by the previous component.
Output Parameter
The output parameter is the selected field.
Function
Associate the dimension table in real time. Three dimension tables are available: the official dimension table (default), custom real-time table, and offline table.
Basic Configuration
Input Parameter
The fields and data types output by the previous component.
Output Parameter
The fields output by the previous component and the field of the associated dimension table.
Difference between Left Join and Inner Join: The pink part is the data after association.
Function
Output data of real-time tasks to the table.
Basic Configuration
Output Parameter
Consistent with the input parameter.
Is this page helpful?
YesFeedbackIs this page helpful?
YesFeedback