Mirrors/miller
1
0
Fork 0
mirror of https://github.com/johnkerl/miller.git synced 2026-07-26 09:23:55 +00:00
Code Issues Projects Releases Wiki Activity

emitn iterate

Browse source
This commit is contained in:
John Kerl 2016-03-25 18:07:44 -04:00
parent 4c21fb3320
commit a04fd90fc9
2 changed files with 83 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

1
c/containers/mlr_dsl_ast.c
View file

@ -166,6 +166,7 @@ char* mlr_dsl_ast_node_describe_type(mlr_dsl_ast_node_type_t type) {
case MD_AST_NODE_TYPE_FILTER: return "filter"; break;
case MD_AST_NODE_TYPE_UNSET: return "unset"; break;
case MD_AST_NODE_TYPE_EMITF: return "emitf"; break;
case MD_AST_NODE_TYPE_EMITN: return "emitn"; break;
case MD_AST_NODE_TYPE_EMIT: return "emit"; break;
case MD_AST_NODE_TYPE_DUMP: return "dump"; break;
case MD_AST_NODE_TYPE_ALL: return "all"; break;

88
c/mapping/mlr_dsl_cst.c
View file

@ -13,7 +13,8 @@ static mlr_dsl_cst_statement_t* cst_statement_alloc_full_srec_from_oosvar_assign
static mlr_dsl_cst_statement_t* cst_statement_alloc_unset(mlr_dsl_ast_node_t* past, int type_inferencing);
static mlr_dsl_cst_statement_t* cst_statement_alloc_unset(mlr_dsl_ast_node_t* past, int type_inferencing);
static mlr_dsl_cst_statement_t* cst_statement_alloc_emitf(mlr_dsl_ast_node_t* past, int type_inferencing);
static mlr_dsl_cst_statement_t* cst_statement_alloc_emit(mlr_dsl_ast_node_t* past, int type_inferencing);
static mlr_dsl_cst_statement_t* cst_statement_alloc_emit_or_emitn(mlr_dsl_ast_node_t* past, int type_inferencing,
int do_full_prefixing);
static mlr_dsl_cst_statement_t* cst_statement_alloc_conditional_block(mlr_dsl_ast_node_t* past, int type_inferencing);
static mlr_dsl_cst_statement_t* cst_statement_alloc_filter(mlr_dsl_ast_node_t* past, int type_inferencing);
static mlr_dsl_cst_statement_t* cst_statement_alloc_dump(mlr_dsl_ast_node_t* past, int type_inferencing);
@ -120,6 +121,26 @@ static void mlr_dsl_cst_node_evaluate_emitf(
int* pshould_emit_rec,
sllv_t* poutrecs);
static void mlr_dsl_cst_node_evaluate_emitn(
mlr_dsl_cst_statement_t* pnode,
mlhmmv_t* poosvars,
lrec_t* pinrec,
lhmsv_t* ptyped_overlay,
string_array_t** ppregex_captures,
context_t* pctx,
int* pshould_emit_rec,
sllv_t* poutrecs);
static void mlr_dsl_cst_node_evaluate_emitn_all(
mlr_dsl_cst_statement_t* pnode,
mlhmmv_t* poosvars,
lrec_t* pinrec,
lhmsv_t* ptyped_overlay,
string_array_t** ppregex_captures,
context_t* pctx,
int* pshould_emit_rec,
sllv_t* poutrecs);
static void mlr_dsl_cst_node_evaluate_emit(
mlr_dsl_cst_statement_t* pnode,
mlhmmv_t* poosvars,
@ -239,8 +260,11 @@ static mlr_dsl_cst_statement_t* cst_statement_alloc(mlr_dsl_ast_node_t* past, in
case MD_AST_NODE_TYPE_EMITF:
return cst_statement_alloc_emitf(past, type_inferencing);
break;
case MD_AST_NODE_TYPE_EMITN:
return cst_statement_alloc_emit_or_emitn(past, type_inferencing, FALSE);
break;
case MD_AST_NODE_TYPE_EMIT:
return cst_statement_alloc_emit(past, type_inferencing);
return cst_statement_alloc_emit_or_emitn(past, type_inferencing, TRUE);
break;
case MD_AST_NODE_TYPE_CONDITIONAL_BLOCK:
return cst_statement_alloc_conditional_block(past, type_inferencing);
@ -482,7 +506,9 @@ static mlr_dsl_cst_statement_t* cst_statement_alloc_emitf(mlr_dsl_ast_node_t* pa
return pstatement;
}
static mlr_dsl_cst_statement_t* cst_statement_alloc_emit(mlr_dsl_ast_node_t* past, int type_inferencing) {
static mlr_dsl_cst_statement_t* cst_statement_alloc_emit_or_emitn(mlr_dsl_ast_node_t* past, int type_inferencing,
int do_full_prefixing)
{
mlr_dsl_cst_statement_t* pstatement = mlr_malloc_or_die(sizeof(mlr_dsl_cst_statement_t));
pstatement->pitems = sllv_alloc();
pstatement->pevaluator = NULL;
@ -509,7 +535,9 @@ static mlr_dsl_cst_statement_t* cst_statement_alloc_emit(mlr_dsl_ast_node_t* pas
NULL,
NULL));
pstatement->pevaluator = mlr_dsl_cst_node_evaluate_emit_all;
pstatement->pevaluator = do_full_prefixing
? mlr_dsl_cst_node_evaluate_emit_all
: mlr_dsl_cst_node_evaluate_emitn_all;
} else if (pnode->type == MD_AST_NODE_TYPE_OOSVAR_NAME || pnode->type == MD_AST_NODE_TYPE_OOSVAR_LEVEL_KEY) {
// First argument is oosvar name (e.g. @sums) or keyed ooosvar name (e.g. @sums[$group]). Remainings
@ -532,7 +560,9 @@ static mlr_dsl_cst_statement_t* cst_statement_alloc_emit(mlr_dsl_ast_node_t* pas
NULL,
NULL));
pstatement->pevaluator = mlr_dsl_cst_node_evaluate_emit;
pstatement->pevaluator = do_full_prefixing
? mlr_dsl_cst_node_evaluate_emit
: mlr_dsl_cst_node_evaluate_emitn;
} else {
fprintf(stderr, "%s: internal coding error detected in file %s at line %d.\n",
@ -963,6 +993,52 @@ static void mlr_dsl_cst_node_evaluate_emitf(
sllv_append(poutrecs, prec_to_emit);
}
// ----------------------------------------------------------------
static void mlr_dsl_cst_node_evaluate_emitn(
mlr_dsl_cst_statement_t* pnode,
mlhmmv_t* poosvars,
lrec_t* pinrec,
lhmsv_t* ptyped_overlay,
string_array_t** ppregex_captures,
context_t* pctx,
int* pshould_emit_rec,
sllv_t* poutrecs)
{
mlr_dsl_cst_statement_item_t* pitem = pnode->pitems->phead->pvvalue;
int all_non_null_or_error = TRUE;
// xxx need two all-non-null, or nested
sllmv_t* pmvkeys = evaluate_list(pitem->poosvar_lhs_keylist_evaluators,
pinrec, ptyped_overlay, poosvars, ppregex_captures, pctx, &all_non_null_or_error);
sllmv_t* pmvnames = evaluate_list(pitem->poosvar_lhs_namelist_evaluators,
pinrec, ptyped_overlay, poosvars, ppregex_captures, pctx, &all_non_null_or_error);
if (all_non_null_or_error) {
mlhmmv_to_lrecs(poosvars, pmvkeys, pmvnames, poutrecs, FALSE);
}
sllmv_free(pmvkeys);
sllmv_free(pmvnames);
}
// ----------------------------------------------------------------
static void mlr_dsl_cst_node_evaluate_emitn_all(
mlr_dsl_cst_statement_t* pnode,
mlhmmv_t* poosvars,
lrec_t* pinrec,
lhmsv_t* ptyped_overlay,
string_array_t** ppregex_captures,
context_t* pctx,
int* pshould_emit_rec,
sllv_t* poutrecs)
{
mlr_dsl_cst_statement_item_t* pitem = pnode->pitems->phead->pvvalue;
int all_non_null_or_error = TRUE;
sllmv_t* pmvnames = evaluate_list(pitem->poosvar_lhs_namelist_evaluators,
pinrec, ptyped_overlay, poosvars, ppregex_captures, pctx, &all_non_null_or_error);
if (all_non_null_or_error) {
mlhmmv_all_to_lrecs(poosvars, pmvnames, poutrecs, FALSE);
}
sllmv_free(pmvnames);
}
// ----------------------------------------------------------------
static void mlr_dsl_cst_node_evaluate_emit(
mlr_dsl_cst_statement_t* pnode,
@ -982,7 +1058,7 @@ static void mlr_dsl_cst_node_evaluate_emit(
sllmv_t* pmvnames = evaluate_list(pitem->poosvar_lhs_namelist_evaluators,
pinrec, ptyped_overlay, poosvars, ppregex_captures, pctx, &all_non_null_or_error);
if (all_non_null_or_error) {
mlhmmv_to_lrecs(poosvars, pmvkeys, pmvnames, poutrecs, TRUE); // xxx impl emitp as well ...
mlhmmv_to_lrecs(poosvars, pmvkeys, pmvnames, poutrecs, TRUE);
}
sllmv_free(pmvkeys);
sllmv_free(pmvnames);