Skip to content

Instantly share code, notes, and snippets.

@tweise
tweise / synthetic_stateful.py
Created September 10, 2020 19:20
Beam performance test for state and timers
#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
@tweise
tweise / metrics.json
Created November 30, 2017 16:17
Dataflow REST API response for metrics API (for Beam quickstart wordcount, https://cloud.google.com/dataflow/docs/reference/rest/v1b3/projects.jobs/getMetrics)
{
"metricTime": "2017-11-30T16:11:13.201Z",
"metrics": [
{
"name": {
"origin": "dataflow/v1b3",
"name": "ExecutionTime_StartBundle",
"context": {
"step": "s12",
"tentative": "true"