hansonkd

-module(example_hook).
-export([postcommit/1]).


postcommit(RObj) ->
    {ok, Client} = riak:local_client(),
    ThisNode = atom_to_binary(node(), latin1),
    UserKey = riak_object:key(RObj),
    
    % The Users value from a riak_dt_map (Map)

hansonkd

user = riak_client.bucket_type('app_objects').bucket('users').get("some_user")
user.registers['email'].assign("[email protected]")
user.store()
user.registers['email'].assign("[email protected]")
user.store()

hansonkd

% Update Counter
increment
decrement
{increment, 4}
{decrement, 9}
% Update Set
{add, <<"Value">>}
{add_all, [<<"Value">>]}
{remove, <<"Value">>}
{remove_all, <<"Value">>}

hansonkd

Updating History for <<”some_user”>>
Users value: [{{<<”email”>>,riak_dt_lwwreg},<<”[email protected]”>>}]
Users history before update: []

Updating History for <<”some_user”>>
Users value: [{{<<”email”>>,riak_dt_lwwreg},<<”[email protected]”>>}]
Users history before update: [{{<<”num_commits”>>,riak_dt_emcntr},1},{{<<”all_emails”>>,riak_dt_orswot},[<<”[email protected]”>>]}]

hansonkd

books = get_book_row_generator_from_csv('mybooks.csv')
formatted_books = list(
    map(
        sorted(
            filter(
                map(
                    books,
                    Book.from_row
                ),
                lambda: book.year >= 1950

hansonkd

books = get_book_row_generator_from_csv('mybooks.csv')

formatted_books = (
    conduit(books)
        .map(Book.from_row)
        .filter(lambda book: book.year >= 1950)
        .sort(lambda book: (book.year, book.author_name.lower()))
        .map('{0.title} | {0.author} ({0.year})'.format)
        .to_list()
)

hansonkd

class Obj(object):
    def method1(self):
        return do_stuff(self)

    def method2(self):
        return do_other_stuff(self)

    def method3(self):
        return do_more_stuff(self)

hansonkd

def func1(obj):
    return do_stuff(obj)

def func2(self):
    return do_other_stuff(obj)

def func3(self):
    return do_more_stuff(obj)

composed = compose(

hansonkd

all_securities = Security.objects.filter(company=company).for_report().iterator()

class FlatData(object):
    pass

def add_issue_date((flat, mdl)):
    flat.issue_date = mdl.get_issue_date()
    return (flat, mdl)

def add_label((flat, mdl)):

hansonkd

all_securities = Security.objects.filter(company=company).for_report().iterator()

def flatten(*args):
    def transform_pipeline(mdl):
        data = FlatData()
        for fn in args:
            fn(data, mdl)
        return data
    return transform_pipeline