Skip to content
This repository was archived by the owner on Nov 11, 2022. It is now read-only.

Conversation

@tgroh
Copy link
Contributor

@tgroh tgroh commented Apr 7, 2016

This backports BEAM #129

tgroh added 2 commits April 11, 2016 14:47
This ensures that user code does not violate the model.

Add a flag to control application of immutability enforcement. This flag
is enabled by default.
Check per-element, to catch failures within a call to ProcessElement
more quickly.

Move wrapping of exceptions over the course of calls to ProcessElement
to ParDoInProcessEvaluator.
@davorbonaci davorbonaci merged commit e08b2be into GoogleCloudPlatform:master Apr 11, 2016
dhalperi pushed a commit that referenced this pull request Apr 14, 2016
Apply ModelEnforcement in the InProcessPipelineRunner
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants