GitHub - akumarseth/appache_beam: Sample code to build big data pipeline (batch and stream) using apache beam in Python

Name		Name	Last commit message	Last commit date
Latest commit History 3 Commits
output		output
source datasets		source datasets
streaming with GCP pubsub		streaming with GCP pubsub
.gitignore		.gitignore
1.ipynb		1.ipynb
10_Pardo_side_outputs.ipynb		10_Pardo_side_outputs.ipynb
2_ParDo.ipynb		2_ParDo.ipynb
3_ParDo.ipynb		3_ParDo.ipynb
4_ParDo.ipynb		4_ParDo.ipynb
5_CoGroupByKey.ipynb		5_CoGroupByKey.ipynb
6_partition.ipynb		6_partition.ipynb
7_flatten.ipynb		7_flatten.ipynb
8_Composite_transformation.ipynb		8_Composite_transformation.ipynb
9_Pardo_side_inputs.ipynb		9_Pardo_side_inputs.ipynb