CountNewsClicks (Flink : Examples : Streaming 2.0.1-cp2 API)

java.lang.Object
- org.apache.flink.streaming.examples.dsv2.eventtime.CountNewsClicks

```
public class CountNewsClicks
extends Object
```
This example illustrates how to count the number of clicks on each news at 1 hour after news publication.
The input consists of a series of CountNewsClicks.NewsEvents, which fall into two categories: news publish and news click. Each CountNewsClicks.NewsEvent contains three components: the event type, the news ID and the timestamp. Notably, there is only one event of type CountNewsClicks.NewsEventType.PUBLISH for each news.
Usage:
- --output <path>The output directory where the Job will write the results. If no output path is provided, the Job will print the results to stdout.
This example shows how to:
- Usage of Event Time extension in DataStream API V2
Please note that if you intend to run this example in an IDE, you must first add the following VM options: "--add-opens=java.base/java.util=ALL-UNNAMED". This is necessary because the module system in JDK 17+ restricts some reflection operations.
Please note that the DataStream API V2 is a new set of APIs, to gradually replace the original DataStream API. It is currently in the experimental stage and is not fully available for production.

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description
`static class`	`CountNewsClicks.CountNewsClicksProcessFunction`	This process function will consume `CountNewsClicks.NewsEvent` and count the number of clicks within 1 hour of the news publication and send the results `CountNewsClicks.NewsClicks` to the output.
`static class`	`CountNewsClicks.NewsClicks`	The `CountNewsClicks.NewsClicks` represents the number of clicks on news within one hour following its publication.
`static class`	`CountNewsClicks.NewsEvent`	The `CountNewsClicks.NewsEvent` represents an event on news, containing the event type, news id and the timestamp.
`static class`	`CountNewsClicks.NewsEventType`	The type of `CountNewsClicks.NewsEvent`, note that only one event of type `CountNewsClicks.NewsEventType.PUBLISH` for each news.

Constructor Summary

Constructors
Constructor Description

CountNewsClicks()

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type Method Description

static void main(String[] args)
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail
- CountNewsClicks
```
public CountNewsClicks()
```

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:: Exception