anchor.diff:                                           StreamProcessCount, FinishedStreamProcessCount, true);
                   false ->
                       spawn_link(fun() ->
  -                        io:format("fold_catalog_process: catalog_query_response: ~p: ~p.~p.~p (~p)~n",
  -                            [Partition, Index, Field, Term, JSONProps]),
  +                        %% io:format("fold_catalog_process: catalog_query_response: ~p: ~p.~p.~p (~p)~n",
  +                        %%     [Partition, Index, Field, Term, JSONProps]),
                           {ok, Conn} = raptor_conn_pool:checkout(),
                           try
                             {ok, StreamRef} = raptor_conn:stream(
  
positive.code:     receive_fold_results(Acc, 0).
  
  is_empty(State) ->
      io:format("is_empty(~p)~n", [State]),
      Partition = to_binary(State#state.partition),
      raptor_command(<<"partition_count">>, Partition, <<"">>, <<"">>) == "0".
  
  
negative.code:         {stream, StreamRef, timeout} ->
              CatalogProcessPid ! {fold_stream, done, StreamRef};
          {stream, StreamRef, "$end_of_table", _} ->
              %% io:format("fold_stream_process: table complete: ~p.~p.~p~n",
              %%     [Index, Field, Term]),
              CatalogProcessPid ! {fold_stream, done, StreamRef};
          {stream, StreamRef, Value, Props} ->
              IndexBin = riak_search_utils:to_binary(Index),
              FieldTermBin = riak_search_utils:to_binary([Field, ".", Term]),
              BObj = term_to_binary({Field, Term, Value, Props}),
              FoldResultPid ! {fold_result, Fun0({IndexBin, FieldTermBin}, BObj, Acc)},
              fold_stream_process(CatalogProcessPid, FoldResultPid, StreamRef, Fun0, Acc, Index, Field, Term);
          _Msg ->
              %% io:format("fold_stream_process: unknown message: ~p~n", [_Msg]),
              fold_stream_process(CatalogProcessPid, FoldResultPid, StreamRef, Fun0, Acc, Index, Field, Term)
          after ?FOLD_TIMEOUT ->
              CatalogProcessPid ! {fold_stream, done, StreamRef},
  