import { Logger } from '@terascope/utils' ; function create ( customConfig , logger ) { const HdfsClient = require ( 'node-webhdfs' ) . WebHDFSClient ; logger . info ( `Using hdfs hosts: ${ customConfig . host }` ) ; const client = new HdfsClient ( customConfig ) ; return { client } ; } export default { create , config_schema ( ) { return { user : { doc : '' , default : 'webuser' } , namenode_port : { doc : '' , default : 50070 } , namenode_host : { doc : '' , default : 'localhost' } , path_prefix : { doc : '' , default : '/webhdfs/v1' } } ; } } ;