     end
   end
 
-  def needs_update(src, sink) do
+  defp needs_update(src, sink) do
     cond do
       is_nil(src) and is_nil(sink) ->
         false

    end
  end

  def create_index(nil), do: nil
  def create_index({t, b, idx, schema}) do
    { :ok, props } = get_bucket(:sink, {t,b})
    case riak_get_index(:sink, idx[:index]) do
      {:ok, sink_idx} ->

    Logger.info("Seconds taken: #{Date.diff(start_date,end_date, :secs)}")
  end

  defp process({[],_}) do
    IO.puts "No commands given"
    print_help
  end

  defp process([command|_args]) do

    Logger.debug("Source: pb://#{config :src_ip}:#{config :src_port}")
    Logger.debug("Target: pb://#{config :sink_ip}:#{config :sink_port}")
