Kenn Knowles questions

Kenn Knowles answers

• Updating/Refreshing side inputs data or passing some additional set of data that can be accessible in transformations while processing main input
• Stateful indexing causes ParDo to be run single-threaded on Dataflow Runner
• Transform node AppliedPTransform was not replaced as expected error with the DirectRunner when mixing Streaming and non steaming source in Apache Beam
• Dataflow reading from Kafka without data loss?
• "No SLF4J providers were found" after adding slf4j-api-2.0.0-alpha1.jar to the project structure and the slf4j dependency to the pom.xml
• Merge two PCollection (Apache beam)
• Using Avrocoder for Custom Types with Generics
• Apache Beam: why is the timestamp of aggregate value in Global Window 9223371950454775?
• How to convert PCollection<List<String>> to PCollection<String> in dataflow/beam
• Dataflow Map side-input issue