1. chango
  2. inferno

Commits

Nan Jiang  committed f62ebd3

fix example_rules.py

  • Participants
  • Parent commits 038fbb6
  • Branches default

Comments (0)

Files changed (2)

File inferno/example_rules/names.py

View file
-from inferno.lib.rule import chunk_csv_keyset_stream
-from inferno.lib.rule import chunk_json_keyset_stream
+from inferno.lib.rule import chunk_csv_stream
 from inferno.lib.rule import chunk_json_stream
 from inferno.lib.rule import InfernoRule
 from inferno.lib.rule import Keyset
     InfernoRule(
         name='last_names_csv',
         source_tags=['example:chunk:users'],
-        map_input_stream=chunk_csv_keyset_stream,
+        map_input_stream=chunk_csv_stream,
         csv_fields=('first', 'last'),
         csv_dialect='excel',
         parts_preprocess=[count],
     InfernoRule(
         name='last_names_result',
         source_tags=['example:chunk:users'],
-        map_input_stream=chunk_json_keyset_stream,
+        map_input_stream=chunk_json_stream,
         parts_preprocess=[count],
         partitions=2,
         key_parts=['last'],
     InfernoRule(
         name='first_and_last_names',
         source_tags=['example:chunk:users'],
-        map_input_stream=chunk_json_keyset_stream,
+        map_input_stream=chunk_json_stream,
         parts_preprocess=[count],
         partitions=2,
         keysets={

File inferno/lib/rule.py

View file
                  # map
                  map_init_function=lambda x, y: x,
                  map_function=keyset_map,
-                 map_input_stream=chunk_csv_keyset_stream,
+                 map_input_stream=chunk_csv_stream,
                  map_output_stream=(
                      map_output_stream, disco_output_stream),