Contents

require 'rflow/components/file/extensions'
require 'rflow/components/file/directory_watcher'
require 'rflow/components/file/output_raw_to_files'

class RFlow
  module Components
    module File
      # Load the schemas
      SCHEMA_DIRECTORY = ::File.expand_path(::File.join(::File.dirname(__FILE__), '..', '..', '..', 'schema'))

      SCHEMA_FILES = {
        'file.avsc' => 'RFlow::Message::Data::File',
      }

      SCHEMA_FILES.each do |file_name, data_type_name|
        schema_string = ::File.read(::File.join(SCHEMA_DIRECTORY, file_name))
        RFlow::Configuration.add_available_data_type data_type_name, 'avro', schema_string
      end

      # Load the data extensions
      RFlow::Configuration.add_available_data_extension('RFlow::Message::Data::File',
                                                        RFlow::Components::File::Extensions::FileExtension)
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
rflow-components-file-1.2.0	lib/rflow/components/file.rb
rflow-components-file-1.1.1	lib/rflow/components/file.rb
rflow-components-file-1.1.0	lib/rflow/components/file.rb
rflow-components-file-1.0.1	lib/rflow/components/file.rb
rflow-components-file-1.0.0	lib/rflow/components/file.rb
rflow-components-file-1.0.0a4	lib/rflow/components/file.rb
rflow-components-file-1.0.0a3	lib/rflow/components/file.rb
rflow-components-file-1.0.0a2	lib/rflow/components/file.rb