I hereby claim:
- I am plugarut on github.
- I am plugarut (https://keybase.io/plugarut) on keybase.
- I have a public key ASAXVb60ITBj501rVzEuCclJFULBvLidu5FC0m95pmlSSgo
To claim this, I am signing this object:
import apache_beam as beam | |
from apache_beam.transforms.window import FixedWindows, GlobalWindows | |
events = [ | |
("k1", {"a": 1, "b":2}), | |
("k1", {"a": 1, "b":2}), | |
("k2", {"a": 1, "b":2}), | |
("k2", {"a": 1, "b":2}), | |
("k3", {"a": 1, "b":2}), | |
("k4", {"a": 1, "b":2}), |
Error message from worker: generic::unknown: Traceback (most recent call last): | |
File "apache_beam/runners/common.py", line 1246, in apache_beam.runners.common.DoFnRunner._invoke_bundle_method | |
File "apache_beam/runners/common.py", line 514, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle | |
File "apache_beam/runners/common.py", line 519, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle | |
File "apache_beam/runners/common.py", line 1416, in apache_beam.runners.common._OutputProcessor.finish_bundle_outputs | |
File "apache_beam/runners/worker/operations.py", line 151, in apache_beam.runners.worker.operations.ConsumerSet.receive | |
File "apache_beam/runners/worker/operations.py", line 153, in apache_beam.runners.worker.operations.ConsumerSet.receive | |
File "apache_beam/runners/worker/operations.py", line 181, in apache_beam.runners.worker.operations.ConsumerSet.update_counters_start | |
File "apache_beam/runners/worker/opcounters.py", line 216, in apache_beam.runners.worker.opcounters.Op |
class WriteToObjectTableBigquery(PTransform): | |
def __init__( | |
self, project: str, dataset: str, window_interval_seconds: int = 20, window_lateness_seconds: int = 10 | |
): | |
super().__init__() | |
self.project = project | |
self.dataset = dataset | |
self.window_interval_seconds = window_interval_seconds | |
self.window_lateness_seconds = window_lateness_seconds |
I hereby claim:
To claim this, I am signing this object:
Verifying my Blockstack ID is secured with the address 15oca1RKDVnhc49xWA7P4ttqB47pN87Yai https://explorer.blockstack.org/address/15oca1RKDVnhc49xWA7P4ttqB47pN87Yai |
class Bar(Foo): | |
pass |
>>> Bar() | |
<__main__.Bar at 0x7f7c94380828> | |
>>> Bar().my_abstract_method() | |
Traceback (most recent call last): | |
File "<stdin>", line 1, in <module> | |
File "<stdin>", line 3, in my_abstract_method | |
NotImplementedError |
# Assume that class Bar inherits from AFoo | |
>>> Bar() | |
Traceback (most recent call last): | |
File "<stdin>", line 1, in <module> | |
TypeError: Can't instantiate abstract class Bar with abstract methods my_abstract_method |
from abc import ABCMeta, abstractmethod | |
class AFoo(metaclass=ABCMeta): | |
@abstractmethod | |
def my_abstract_method(self): | |
pass |
class Foo: | |
def my_abstract_method(self): | |
raise NotImplementedError |