lib/rflow/components/raw.rb in rflow-0.0.5 vs lib/rflow/components/raw.rb in rflow-1.0.0a1
- old
+ new
@@ -1,26 +1,26 @@
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