Skip to content

Add AggregateStats directive with ByteSize and TimeDuration parsing#973

Open
rahulmarripudi wants to merge 13 commits intodata-integrations:developfrom
rahulmarripudi:develop
Open

Add AggregateStats directive with ByteSize and TimeDuration parsing#973
rahulmarripudi wants to merge 13 commits intodata-integrations:developfrom
rahulmarripudi:develop

Conversation

@rahulmarripudi
Copy link

Summary

This PR introduces a new directive called AggregateStats that enables aggregation of data size and duration metrics from records.

Key Changes

  • Implemented ByteSize.java and TimeDuration.java to parse human-readable units (e.g., "10KB", "5ms").
  • Added AggregateStats.java directive to compute total size (in MB) and time (in seconds).
  • Updated grammar files and parser visitors to support ByteSize and TimeDuration types.
  • Included unit tests:
    • ByteSizeTests.java and TimeDurationTests.java
    • Testing Rig-based directive tests

Example Usage

aggregate-stats : data_size :duration total_size_mb total_time_sec

@google-cla
Copy link

google-cla bot commented Apr 15, 2025

Thanks for your pull request! It looks like this may be your first contribution to a Google open source project. Before we can look at your pull request, you'll need to sign a Contributor License Agreement (CLA).

View this failed invocation of the CLA check for more information.

For the most up to date status, view the checks section at the bottom of the pull request.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant