jkff

jkff has asked 31 questions and find answers to 77 problems.

Stats

About

I'm Eugene Kirpichov and I work on Google Cloud Dataflow and Apache Beam.

jkff questions

Articles about replication schemes/algorithms?
Does there exist an open-source distributed logging library?
How can I improve performance of TextIO or AvroIO when reading a very large number of files?
I want to write a tool without usage entry barriers. Do I have to write it in C? [closed]
Making Java Swing applications persistent
How to visualize the behavior of many concurrent multi-stage processes?
How to stream the output of a programmatically executed ScriptBlock?
Watching for new files matching a filepattern in Apache Beam
Why does the TensorFlow Estimator API take inputs as a lambda?
What is a "tagged DFA"?

jkff answers

yield results in `finish_bundle` from a custom DoFn
Scaling of ParDo transforms having blocking network calls
How to get the current dataflow job's details using the Java SDK?
How to query datastore from dataflow/beam in python
Apache Beam : Transform an objects having a list of objects to multiple TableRows to write to BigQuery
BigQueryIO.read() performance very slow - Apache Beam
Can I pass side inputs to Apache Beam PTransforms?
Is there any way to set numWorkers dynamically in the middle of dataflow job running?
How can you replay old data into dataflow via pub/sub and maintain correct event time logic?
How to use memcache in dataflow?