Apache Flink Stream processing

I am new to flink and I am need help with Windowing function.

I have a stream (for now lets say we are reading 100 elements through a file in my local).

For example, lets say we get a stream of price tickers:

{"eventTime": "2020-10-21T18:08:34.269973", "ticker": "AAPL", "price": 32.57}

{"eventTime": "2020-10-21T18:08:34.793659", "ticker": "TBV", "price": 5.69}

{"eventTime": "2020-10-21T18:08:34.890711", "ticker": "INTC", "price": 24.27}

{"eventTime": "2020-10-21T18:08:34.984684", "ticker": "MSFT", "price": 48.21}

I need to write flink code:

How many AAPL stocks came in a minute?

Out of 100 stocks how many AAPL stocks were above $50?

All this needs to be done in local eclipse IDE.

I need help where I/you share screen and you walk me through an example and help me understand the code.

And I have few more questions where I need help.

Навыки: Java, Linux, PHP, Архитектура ПО, Программирование на С

Показать больше: apache flink architecture, apache flink vs kafka, apache flink github, apache flink tutorial, apache flink use cases, apache flink example, stream processing with apache flink pdf github, apache flink vs spark, solutions review questions database processing textbook, webcam stream video linux apache, mac apache processing php, data processing technician numerical reasoning sample test questions, warning failed open stream linux apache php txt, bash scripts apache log files processing, data processing questions, digital signal processing viva questions, multiple choice questions concepts information data processing, processing questions, questions digital signal processing, signal processing questions

ID проекта: #27946198