2017-12-14 7 views
2

.datファイルをIPルックアップに使用しようとしています。ファイルには、ScalaのコードからDatabricksファイルストアにある:Databricks FileStoreからファイルを使用する方法

def getCountryCode(ip: String) { 
    val filePath = "FileStore/maxmind/GeoIPCountry.dat" 
    val ipLookups = new IpLookups(geoFile = Option(new File(filePath)), 
    ispFile = None, orgFile = None, domainFile = None, memCache = false, lruCache = 0) 

    val location = ipLookups.performLookups(ip)._1.head 
    println(location.countryCode) 
    } 

私は例外を取得しています:

java.io.FileNotFoundException: FileStore/maxmind/GeoIPCountry.dat (No such file or directory) 

方法は、相対/絶対パスでローカル環境で動作します

答えて

2

するために使用する完全修飾パスFUSEマウントされたファイルシステムのファイル:

val filePath = "/dbfs/FileStore/maxmind/GeoIPCountry.dat" 

参照:Using Local File I/O APIs

関連する問題