Skip to content
Snippets Groups Projects
Commit be8c00c6 authored by Carol7102's avatar Carol7102
Browse files

change parser

parent 5f7e44cc
Branches test
No related tags found
1 merge request!1change parser
Hide whitespace changes
Inline Side-by-side
Showing
with 5 additions and 0 deletions
sql/sqlParser.go
+ 5
− 0
View file @ be8c00c6
...@@ -367,6 +367,11 @@ func (parser *Parser) runJoinQueryUsingHadoop() error { ...@@ -367,6 +367,11 @@ func (parser *Parser) runJoinQueryUsingHadoop() error {
log.Println(cmd.String()) log.Println(cmd.String())
_ = cmd.Run() _ = cmd.Run()
// upload merged file to HDFS
cmd = exec.Command("rm", merged_d1d2)
log.Println(cmd.String())
_ = cmd.Run()
cmd = exec.Command("hadoop", "fs", "-put", merged_d1d2, "/") cmd = exec.Command("hadoop", "fs", "-put", merged_d1d2, "/")
log.Println(cmd.String()) log.Println(cmd.String())
err = cmd.Run() err = cmd.Run()
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment