Move files to HDFS using Spring XD -

-

how move files local disk hdfs using spring xd.

i not want contents , move whole file archival saves file original name , content.

here have tried

stream create --name fileapple --definition "file --mode=ref --dir=/users/dev/code/open/learnspringxd/input --pattern=apple*.txt | whattodohere"

i can see reference file names full path made available , how move hdfs.

you might want check this imports data files hdfs batch job , check if fits requirement. can check file | hdfs stream if works you.


Comments

Post a Comment

Popular posts from this blog

qt - Using float or double for own QML classes -

-
i've created components , helper methods using c++ , qt used in qml gui. of methods calculate gui elements (size, transformations, scene graph items creation). target arm 32 bit using opengl / eglfs render output. opengl using float , qml using real (defined double ). what should use in c++ do not lose precision? if use qreal ( double ) shouldn't lose precision. if git grep float in qtbase.git , can find out bit more: dist/changes-5.2.0-**************************************************************************** dist/changes-5.2.0-* important behavior changes * dist/changes-5.2.0-**************************************************************************** dist/changes-5.2.0- dist/changes-5.2.0- - qt compiled qreal typedef'ed double on dist/changes-5.2.0: platforms. qreal float on arm chipsets before. guarantees more dist/changes-5.2.0- consistent behavior between platforms qt supports, binary dist/chan...
Read more

json - ORA-06502: PL/SQL: numeric or value error: character string buffer too small - Convert Clob to varchar2 -

-
im getting error while trying convert clob varchar2 using api. the 'body' field im trying retrieve clob, want convert varchar2(1000). please advice why error occurred : merge xxx d using ( select v_ticket_id ticket_id, json_ext.get_number(json(value(s)),'id') comment_id, json_ext.get_number(json(value(s)),'author_id') author_id , dbms_lob.substr(json_ext.get_string(json(value(s)),'body'),1000,1) body, json_ext.get_string(json(value(s)),'via.channel')channel, case when lower(json(value(s)).get('public').to_char()) = 'true' 1 else 0 end is_public, to_date(replace(replace(json_ext.get_string(json(value(s)),'created_at'),'t',' '),'z',nul...
Read more

ios - Swift Array Resetting Itself -

-
i have 2 arrays: pointhistory , datehistory . have nstimer , , when timer runs out, action called. in action appending int pointhistory , , current date string datehistory . here timer action: func timeraction() { let steppervalue = int(stepper.value) employee.numberofpoints = steppervalue networking.saveemployee(employee, completion: { (error) -> void in if error != nil { let alert = uialertcontroller(title: "error", message: "there error updating \(self.employee.name)'s points", preferredstyle: .alert) let alertaction = uialertaction(title: "ok", style: .cancel, handler: nil) alert.addaction(alertaction) self.presentviewcontroller(alert, animated: true, completion: nil) } }) var dateformatter = nsdateformatter() dateformatter.dateformat = "mm-dd-yyyy" dateformatter.timezone = nstimezone.localtimezone() var date = nsdate() var ...
Read more