Mirrors/miller
1
0
Fork 0
mirror of https://github.com/johnkerl/miller.git synced 2026-07-24 08:28:18 +00:00
Code Issues Projects Releases Wiki Activity

emit-write iterate

Browse source
This commit is contained in:
John Kerl 2016-07-20 22:43:50 -04:00
parent a6c68ab74d
commit 7174ffdef7
1 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

10
c/mapping/mlr_dsl_cst.c
View file

@ -882,6 +882,7 @@ static mlr_dsl_cst_statement_t* alloc_emitf_append(mlr_dsl_ast_node_t* pnode, in
pstatement->poutput_filename_evaluator = rval_evaluator_alloc_from_ast(pfilenode,
type_inferencing, context_flags);
pstatement->pmulti_lrec_writer = multi_lrec_writer_alloc();
pstatement->pnode_handler = handle_emitf_append;
return pstatement;
@ -2278,7 +2279,6 @@ static void handle_emitf_write(
multi_lrec_writer_write(pnode->pmulti_lrec_writer, poutrecs, filename.u.strv, TRUE/*flush_every_record*/);
sllv_free(poutrecs);
mv_free(&filename);
}
@ -2291,6 +2291,7 @@ static void handle_emitf_append(
mv_t filename = poutput_filename_evaluator->pprocess_func(poutput_filename_evaluator->pvstate, pvars);
lrec_t* prec_to_emit = lrec_unbacked_alloc();
sllv_t* poutrecs = sllv_alloc();
for (sllve_t* pf = pnode->pvarargs->phead; pf != NULL; pf = pf->pnext) {
mlr_dsl_cst_statement_vararg_t* pvararg = pf->pvvalue;
char* emitf_or_unset_srec_field_name = pvararg->emitf_or_unset_srec_field_name;
@ -2310,8 +2311,13 @@ static void handle_emitf_append(
}
}
sllv_append(pcst_outputs->poutrecs, prec_to_emit);
sllv_append(poutrecs, prec_to_emit);
// xxx to-string ...
// xxx flush param ...
multi_lrec_writer_append(pnode->pmulti_lrec_writer, poutrecs, filename.u.strv, TRUE/*flush_every_record*/);
sllv_free(poutrecs);
mv_free(&filename);
}