В WebHDFS examples показано, как перечислять файлы и папки в hdf, создавать каталог и загружать файл с помощью BigInsights WebHDFS?Как загрузить файл, используя библиотеку grochy knox WebHDFS?
Как я могу адаптировать примеры для загрузки файла для BigInsights WebHDFS?
Нокс api documentation содержит много других примеров, например.
import groovy.json.JsonSlurper
import org.apache.hadoop.gateway.shell.Hadoop
import org.apache.hadoop.gateway.shell.hdfs.Hdfs
gateway = "https://localhost:8443/gateway/sample"
username = "bob"
password = "bob-password"
dataFile = "README"
session = Hadoop.login(gateway, username, password)
text = Hdfs.get(session).from("/tmp/example/README").now().string
file = new File('README')
file << text
session.shutdown()