Kvswap
Takes a collection of key-value pairs and returns a collection of key-value pairs
which has each key and value swapped.
Examples
In the following example, we create a pipeline with a PCollection
of key-value pairs.
Then, we apply KvSwap
to swap the keys and values.
import apache_beam as beam
with beam.Pipeline() as pipeline:
plants = (
pipeline
| 'Garden plants' >> beam.Create([
('🍓', 'Strawberry'),
('🥕', 'Carrot'),
('🍆', 'Eggplant'),
('🍅', 'Tomato'),
('🥔', 'Potato'),
])
| 'Key-Value swap' >> beam.KvSwap()
| beam.Map(print))
Output:
('Strawberry', '🍓')
('Carrot', '🥕')
('Eggplant', '🍆')
('Tomato', '🍅')
('Potato', '🥔')
- Keys for extracting the key of each component.
- Values for extracting the value of each element.