anchor.diff:  name_default(N) ->
       [list_to_binary(lists:flatten("col",integer_to_list(I))) || I <- lists:seq(1, N)].
   
  -fetch_start(Pid, {Schema,FileName}, MatchSpec, BlockSize, Opts) ->
  +fetch_start(Pid, {Schema,FileName}, MatchSpec, BlockSize, RowCount, Opts) ->
       UnquotedFN = imem_datatype:strip_dquotes(FileName),
       % ?LogDebug("UnquotedFN : ~p", [UnquotedFN]),
       F =
  
positive.code:                 case Contd0 of
                          undefined ->
                              % ?Info("[~p] got MatchSpec ~p for ~p limit ~p~n", [Pid,MatchSpec,FileName,BlockSize]),
                              case select({Schema,UnquotedFN}, MatchSpec, BlockSize, read) of
                                  '$end_of_table' ->
                                      % ?Info("[~p] got empty table~n", [Pid]),
                                      Pid ! {row, [?sot,?eot]};
  
negative.code:         , terminate/2
          , code_change/3
          , format_status/2
          , read_blocks/4
          , start_link/1
          ]).
  
  -export([select/5, column_names/1, fetch_start/6]).
  
  start_link(Params) ->
      ?Info("~p starting...~n", [?MODULE]),
  