mattsnyder

brew install riak
edit /usr/local/Cellar/riak/<riak version>/libexec/etc/app.config

  change
    {storage_backend, riak_kv_bitcask_backend},
  to
    {storage_backend, riak_kv_eleveldb_backend},

ulimit -n 1024
riak start

mattsnyder

include Ripple::Document

property :custom_key, String
key_on :custom_key
before_save :set_key
def set_key
  self[:custom_key] ||= "#{self.created_at.utc.to_s(:key)}-#{SecureRandom.hex(8)}"
  self[:custom_key]
end
private :set_key

mattsnyder

module Ripple
  module Document
    module DynamicFinders
      class << self
        def included(base)
          base.module_eval do
            extend DynamicFindersClassMethods
          end
        end
      end

mattsnyder

class FasterCSV
  def <<(row)
    # make sure headers have been assigned
    if header_row? and [Array, String].include? @use_headers.class
      parse_headers  # won't read data for Array or String
      self << @headers if @write_headers
    end

    # Handle FasterCSV::Row objects and Hashes
    row = case row

mattsnyder

namespace :b2b2dot0 do
  namespace :magento do
    desc "Imports some stuff from one place to another"
    task :import_stuff => :environment do
      benchmark = Benchmark.measure do
        # The import stuff here
        SomeStuff.import do |stuff|
          stuff.do_something_more
        end 
      end.real

mattsnyder

def log(string)
  string.split(/\n/).each do |line|
    puts "[#{Time.now.strftime("%Y-%m-%d %H:%M:%S")}] #{line}"
  end
end

mattsnyder

MyModel.find_by_index('$key', '20121001'..'20130117')

mattsnyder

 Riak::MapReduce.new(Ripple.client).
        add(@bucket_to_filter,
            [
             [:tokenize, "-", 1], #Note: 1 based index
             [:between, start_time.to_s(:key), end_time.to_s(:key)]
            ])

mattsnyder

var links = value.values[0].metadata.Links;
links.filter(function(element, index, array){ return element[0] == 'tag'}).length;

mattsnyder

RSpec::Matchers.define :be_a_ripple_document do
  match do |doc|
    doc.class.included_modules.include?(Ripple::Document) ||
      doc.class.included_modules.include?(Ripple::EmbeddedDocument)
  end

  failure_message_for_should do
    "#{actual.class.to_s} should be a Ripple::Document"
  end