Skip to content

[Timeseries] Make processing time hint in seconds available in tests#65

Open
dsdinter wants to merge 1 commit intomasterfrom
processing_time_hint
Open

[Timeseries] Make processing time hint in seconds available in tests#65
dsdinter wants to merge 1 commit intomasterfrom
processing_time_hint

Conversation

@dsdinter
Copy link
Collaborator

@dsdinter dsdinter commented Feb 9, 2021

No description provided.

@dsdinter dsdinter requested a review from rezarokni February 9, 2021 12:19
testStream = stream.advanceWatermarkToInfinity();
}
break;
case ADVANCE_PROCESSING_TIME_SECONDS:
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I think the other use case we need is to advance the watermark but then have a event that has timestamp > than the watermark.

For example:

event{timestamp: 1}
advanceWaterMark timestamp: 3
event{timestamp: 2}

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.

2 participants