require 'rflow/components/raw/extensions' class RFlow module Components module Raw # Load the schemas SCHEMA_DIRECTORY = ::File.expand_path(::File.join(::File.dirname(__FILE__), '..', '..', '..', 'schema')) SCHEMA_FILES = { 'raw.avsc' => 'RFlow::Message::Data::Raw', } 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::Raw', RFlow::Components::Raw::Extensions::RawExtension) end end end