Hello Team,
We are trying to test the following behavior by replacing the *default*
trigger in WindowingStrategy:
https://github.com/apache/beam/blob/3b2b07d251f58ec00a0056ac368b443fea2f10d9/sdks/go/pkg/beam/core/runtime/graphx/translate.go
Before:
ws := &pipepb.WindowingStrategy{
WindowFn: windowFn,
MergeStatus: pipepb.MergeStatus_NON_MERGING,
AccumulationMode: pipepb.AccumulationMode_DISCARDING,
WindowCoderId: windowCoderId,
Trigger: &pipepb.Trigger{
*Trigger: &pipepb.Trigger_Default_{*
* Default: &pipepb.Trigger_Default{},*
* },*
},
After:
ws := &pipepb.WindowingStrategy{
WindowFn: windowFn,
MergeStatus: pipepb.MergeStatus_NON_MERGING,
AccumulationMode: pipepb.AccumulationMode_DISCARDING,
WindowCoderId: windowCoderId,
Trigger: &pipepb.Trigger{
*Trigger: &pipepb.Trigger_Always_{*
* Always: &pipepb.Trigger_Always{},*
* },*
},
Despite having changed the default code, the behavior doesn't change. See
the below console output:
windowing_strategies:
key: "w0"
value: <
window_fn: <
urn: "beam:window_fn:global_windows:v1"
>
merge_status: NON_MERGING
window_coder_id: "c4"
*trigger: < default: <*
>
>
accumulation_mode: DISCARDING
output_time: END_OF_WINDOW
closing_behavior: EMIT_IF_NONEMPTY
OnTimeBehavior: FIRE_ALWAYS
environment_id: "go"
This is just to check if the runner acknowledges the change before we
implement different triggers.
Please let us know if we are missing something.
Thank you,
-Cesar
--
*This email and its contents (including any attachments) are being sent to
you on the condition of confidentiality and may be protected by legal
privilege. Access to this email by anyone other than the intended recipient
is unauthorized. If you are not the intended recipient, please immediately
notify the sender by replying to this message and delete the material
immediately from your system. Any further use, dissemination, distribution
or reproduction of this email is strictly prohibited. Further, no
representation is made with respect to any content contained in this email.*
