Skip to content

Instantly share code, notes, and snippets.

View brunoripa's full-sized avatar

Bruno Ripa brunoripa

View GitHub Profile

class Split(apache_beam.DoFn):

def process(self, element):
    country, duration, user = element.split(",")

    return [{
        'country': country,
        'duration': float(duration),
        'user': user

}]

Verifying my Blockstack ID is secured with the address 1NtWtFZB35YPSTSeCfFQiu6uGB5CWvU9dD https://explorer.blockstack.org/address/1NtWtFZB35YPSTSeCfFQiu6uGB5CWvU9dD
from abc import ABCMeta, abstractmethod
class ConfigurationPort(metaclass=ABCMeta):
@abstractmethod
def get(self, key):
pass