feat(examples): reduce streaming example

[vigith]

{"timestamp":"2025-11-30T17:56:12.145344Z","level":"INFO","message":"Payload - counter:10 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-37-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:12.145354Z","level":"INFO","message":"Payload - counter:20 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-38-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:13.067117Z","level":"INFO","message":"Processed messages per second","processed":"3","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:14.065666Z","level":"INFO","message":"Processed messages per second","processed":"0","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:14.150386Z","level":"INFO","message":"Payload - counter:30 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-39-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:15.070012Z","level":"INFO","message":"Processed messages per second","processed":"1","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:15.155129Z","level":"INFO","message":"Payload - counter:40 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-40-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:16.069687Z","level":"INFO","message":"Processed messages per second","processed":"1","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:16.156775Z","level":"INFO","message":"Payload - counter:50 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-41-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:17.066363Z","level":"INFO","message":"Processed messages per second","processed":"1","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:17.158887Z","level":"INFO","message":"Payload - counter:60 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-42-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:18.069909Z","level":"INFO","message":"Processed messages per second","processed":"1","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:18.161599Z","level":"INFO","message":"Payload - counter:70 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-43-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:19.065768Z","level":"INFO","message":"Processed messages per second","processed":"1","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:19.164776Z","level":"INFO","message":"Payload - counter:80 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-44-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:20.066241Z","level":"INFO","message":"Processed messages per second","processed":"1","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:20.167875Z","level":"INFO","message":"Payload - counter:90 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-45-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:21.065881Z","level":"INFO","message":"Processed messages per second","processed":"1","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:21.170123Z","level":"INFO","message":"Payload - counter:100 interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-46-0-0","target":"numaflow_core::sinker::sink::log"}
{"timestamp":"2025-11-30T17:56:22.066663Z","level":"INFO","message":"Processed messages per second","processed":"1","target":"numaflow_core::tracker"}
{"timestamp":"2025-11-30T17:56:22.174965Z","level":"INFO","message":"Payload - counter:100 (FINAL) interval_window_start:2025-11-30 17:56:10+00:00 interval_window_end:2025-11-30 17:56:20+00:00 Keys -  EventTime - 1764525379999 Headers -  ID - sink-47-0-0","target":"numaflow_core::sinker::sink::log"}

[codecov]

Codecov Report

✅ All modified and coverable lines are covered by tests.
✅ Project coverage is 93.85%. Comparing base (0e2bafe) to head (d37fd61).
⚠️ Report is 1 commits behind head on main.

Additional details and impacted files

@@           Coverage Diff           @@
##             main     #291   +/-   ##
=======================================
  Coverage   93.85%   93.85%           
=======================================
  Files          66       66           
  Lines        3009     3009           
  Branches      155      155           
=======================================
  Hits         2824     2824           
  Misses        135      135           
  Partials       50       50           

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:

• ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

[BulkBeing]

nit: log.info instead of print ?

[vigith]

i was using native entities so far in examples as much as possible