Add TestStreamPayload to Runner API proto
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f5e30c52 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f5e30c52 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f5e30c52 Branch: refs/heads/master Commit: f5e30c52b46787133651463f343c02113f08c63c Parents: 9c3fbc3 Author: Kenneth Knowles <[email protected]> Authored: Thu Jun 1 16:32:47 2017 -0700 Committer: Kenneth Knowles <[email protected]> Committed: Fri Jun 2 10:06:52 2017 -0700 ---------------------------------------------------------------------- .../src/main/proto/beam_runner_api.proto | 33 ++++++++++++++++++++ 1 file changed, 33 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/f5e30c52/sdks/common/runner-api/src/main/proto/beam_runner_api.proto ---------------------------------------------------------------------- diff --git a/sdks/common/runner-api/src/main/proto/beam_runner_api.proto b/sdks/common/runner-api/src/main/proto/beam_runner_api.proto index acc4a35..87e33f0 100644 --- a/sdks/common/runner-api/src/main/proto/beam_runner_api.proto +++ b/sdks/common/runner-api/src/main/proto/beam_runner_api.proto @@ -325,6 +325,39 @@ message CombinePayload { map<string, SideInput> side_inputs = 4; } +// The payload for the test-only primitive TestStream +message TestStreamPayload { + + // (Required) the coder for elements in the TestStream events + string coder_id = 1; + + repeated Event events = 2; + + message Event { + oneof event { + AdvanceWatermark watermark_event = 1; + AdvanceProcessingTime processing_time_event = 2; + AddElements element_event = 3; + } + + message AdvanceWatermark { + int64 new_watermark = 1; + } + + message AdvanceProcessingTime { + int64 advance_duration = 1; + } + + message AddElements { + repeated TimestampedElement elements = 1; + } + } + + message TimestampedElement { + bytes encoded_element = 1; + int64 timestamp = 2; + } +} // The payload for the special-but-not-primitive WriteFiles transform. message WriteFilesPayload {
