[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37067:
-------------------------------
Description:
In Flink 2.0, we have introduce DataStream API V2. To verify this feature, you
should test four scenarios:
1. Write a stateful DataStream program, such as WordCount. Use ProcessFunction
to receive and process data, and use State to store the state. You can refer to
the documentation:
# docs/content/docs/dev/datastream-v2/context_and_state_processing.md
2. Write a window aggregation job using the event time extension and verify it.
You can refer to the documentation:
# Event Time
## docs/content/docs/dev/datastream-v2/time-processing/event_timer_service.md
## Examples listed in [FLIP-499: Support Event Time in DataStream
V2|https://cwiki.apache.org/confluence/x/pQz0Ew]
# Window
## docs/content.zh/docs/dev/datastream-v2/builtin-funcs/windows.md
## Examples listed in [FLIP-501: Support Window in DataStream
V2|https://cwiki.apache.org/confluence/x/z4kgF]
3. Write a Join job using the BuiltinFuncs#join and verify it. You can refer to
the documentation:
# docs/content/docs/dev/datastream-v2/builtin-funcs/joining.md
# Examples listed in [FLIP-500: Support Join in DataStream
V2|https://cwiki.apache.org/confluence/x/ywz0Ew]
4. Write a job define and using the Watermark and verify it. You can refer to
the documentation:
# docs/content.zh/docs/dev/datastream-v2/watermark.md
# Examples listed in [FLIP-467: Introduce Generalized
Watermarks|https://cwiki.apache.org/confluence/x/oA6TEg]
was:
In Flink 2.0, we have introduce DataStream API V2. To verify this feature, you
should test four scenarios:
1. Write a stateful DataStream program, such as WordCount. Use ProcessFunction
to receive and process data, and use State to store the state. You can refer to
the documentation:
docs/content/docs/dev/datastream-v2/context_and_state_processing.md
2. Write a window aggregation job using the event time extension and verify it.
You can refer to the documentation:
Event Time
docs/content/docs/dev/datastream-v2/time-processing/event_timer_service.md
Examples listed in FLIP-499: Support Event Time in DataStream V2
Window
docs/content.zh/docs/dev/datastream-v2/builtin-funcs/windows.md
Examples listed in FLIP-501: Support Window in DataStream V2
3. Write a Join job using the BuiltinFuncs#join and verify it. You can refer to
the documentation:
docs/content/docs/dev/datastream-v2/builtin-funcs/joining.md
Examples listed in FLIP-500: Support Join in DataStream V2
4. Write a job define and using the Watermark and verify it. You can refer to
the documentation:
docs/content.zh/docs/dev/datastream-v2/watermark.md
Examples listed in FLIP-467: Introduce Generalized Watermarks
> Cross-team verification for “Introduce DataStream API V2”
> ---------------------------------------------------------
>
> Key: FLINK-37067
> URL: https://issues.apache.org/jira/browse/FLINK-37067
> Project: Flink
> Issue Type: Sub-task
> Reporter: Xintong Song
> Priority: Blocker
> Fix For: 2.0.0
>
>
> In Flink 2.0, we have introduce DataStream API V2. To verify this feature,
> you should test four scenarios:
> 1. Write a stateful DataStream program, such as WordCount. Use
> ProcessFunction to receive and process data, and use State to store the
> state. You can refer to the documentation:
> # docs/content/docs/dev/datastream-v2/context_and_state_processing.md
> 2. Write a window aggregation job using the event time extension and verify
> it. You can refer to the documentation:
> # Event Time
> ## docs/content/docs/dev/datastream-v2/time-processing/event_timer_service.md
> ## Examples listed in [FLIP-499: Support Event Time in DataStream
> V2|https://cwiki.apache.org/confluence/x/pQz0Ew]
> # Window
> ## docs/content.zh/docs/dev/datastream-v2/builtin-funcs/windows.md
> ## Examples listed in [FLIP-501: Support Window in DataStream
> V2|https://cwiki.apache.org/confluence/x/z4kgF]
> 3. Write a Join job using the BuiltinFuncs#join and verify it. You can refer
> to the documentation:
> # docs/content/docs/dev/datastream-v2/builtin-funcs/joining.md
> # Examples listed in [FLIP-500: Support Join in DataStream
> V2|https://cwiki.apache.org/confluence/x/ywz0Ew]
> 4. Write a job define and using the Watermark and verify it. You can refer to
> the documentation:
> # docs/content.zh/docs/dev/datastream-v2/watermark.md
> # Examples listed in [FLIP-467: Introduce Generalized
> Watermarks|https://cwiki.apache.org/confluence/x/oA6TEg]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
