anchor.diff:  
   %% a runner for time series dev
   
  --export([
  -	 setup/0,
  -	 show/0,
  -	 load/0,
  -	 dump/0,
  -	 prep_q/0,
  -	 qry/0,
  -	 qry/1,
  -	 get_ddl/0
  -	 % bounce_qry/0
  -	]).
  +-compile([export_all]).
   
  --include("riak_kv_ddl.hrl").
  +%% -export([
  +%% 	 %% setup/0,
  +%% 	 show/0
  +%% 	 %% load/0,
  +%% 	 %% dump/0
  +%% 	 %% prep_q/0,
  +%% 	 %% qry/0,
  +%% 	 %% qry/1,
  +%% 	 %% get_ddl/0
  +%% 	 % bounce_qry/0
  +%% 	]).
  +
  +%% -include_lib("riak_ql/include/riak_ql_ddl.hrl").
   -include_lib("riak_kv/include/riak_kv_index.hrl").
   -include_lib("riak_kv/src/riak_kv_wm_raw.hrl").
   
  
positive.code:     Temp = list_to_binary(N2),
      Obj = {Geohash, User, Time, Weather, Temp},
      case Mod:validate_obj(Obj) of
  	true  -> PK = riak_kv_ddl:get_partition_key(DDL, Obj),
  		 LK = riak_kv_ddl:get_local_key(DDL, Obj),
  		 {PK, LK, Obj};
  	false -> exit("borked object")
      end.
  
negative.code:     Client = riak_client:new(node(), ?CLIENTID),
      _Props = riak_client:get_bucket(?BUCKET, Client).
  
  %% execute_qry(DDL, Q) ->
  %%     SubQueries = riak_kv_qry_compiler:compile(DDL, Q),
  %%     io:format("in ts_runner:execute_qry SubQueries is ~p~n", [SubQueries]),
  %%     bombaste.
      %% Bucket = Q#riak_kv_li_index_v1.bucket,
      %% %% fix these up too
      %% Timeout = {timeout, 10000},
  