lib/wukong/streamer/base.rb in wukong-1.4.0 vs lib/wukong/streamer/base.rb in wukong-1.4.1

@@ -15,9 +15,10 @@
 
       #
       # Pass each record to +#process+
       #
       def stream
+        Log.info("Streaming on:\t%s" % [Script.input_file])
         before_stream
         $stdin.each do |line|
           record = recordize(line.chomp)
           next unless record
           process(*record) do |output_record|