data_format

in lib/fluent/plugin/kinesis_helper/format.rb [33:42]

• 9 lines of code
• 3 McCabe index (conditional complexity)

      def data_format(tag, time, record)
        if @data_key and record[@data_key].nil?
          raise KeyNotFoundError.new(@data_key, record)
        elsif @data_key
          record[@data_key].to_s
        else
          @formatter.format(tag, time, record).chomp
        end
      end