logstash-core/lib/logstash/pipeline.rb
def flush_filters_to_batch(batch, options = {})
    flush_filters(options) do |event|
      return if @force_shutdown.true?

      unless event.cancelled?
        @logger.debug? and @logger.debug("Pushing flushed events", default_logging_keys(:event => event))
        batch.merge(event)
      end
    end

    @flushing.set(false)
  end
# perform filters flush into the output queue
#
# @param batch [ReadClient::ReadBatch]
# @param options [Hash]
perform filters flush into the output queue
perform filters flush into the output queue
def flush_filters_to_batch(batch, options = {})
    flush_filters(options) do |event|
      return if @force_shutdown.true?
      unless event.cancelled?
        @logger.debug? and @logger.debug("Pushing flushed events", default_logging_keys(:event => event))
        batch.merge(event)
      end
    end
    @flushing.set(false)
  end
def flush_filters_to_batch ( batch , options = { } ) flush_filters ( options ) do | event | return if @force_shutdown . true? unless event . cancelled? @logger . debug? and @logger . debug ( "Pushing flushed events" , default_logging_keys ( :event => event ) ) batch . merge ( event ) end end @flushing . set ( false ) end
perform filters flush into the output queue
perform filters flush into the output queue
batch
options
None