Contents

require "lock_jar"

LockJar.load

module Viking

  java_import java.net.URI
  java_import org.apache.hadoop.fs.FileSystem
  java_import org.apache.hadoop.hdfs.DistributedFileSystem
  java_import org.apache.hadoop.conf.Configuration
  java_import org.apache.hadoop.fs.Path
  java_import org.apache.hadoop.fs.permission.FsPermission

  def self.configure(config)
    hostname = config[:host]
    port     = config[:port]

    path = URI.new("hdfs://#{hostname}:#{port}")

    @client = DistributedFileSystem.new
    @client.initialize__method(path, Configuration.new)
  end

  def self.client
    @client ||= FileSystem.get_local(Configuration.new)
  end
end

require "viking/version"
require 'viking/file'
require 'viking/dir'
require 'viking/fileutilz'

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
hdfs-viking-0.0.5	lib/viking.rb
hdfs-viking-0.0.4	lib/viking.rb