jkff

jkff has asked 31 questions and find answers to 62 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

TextIO.Write - does it append to or replace the output files (Google Cloud Dataflow)
Why are zero byte files written to GCS when running a pipeline?
Coder Not found when processing Multiple PCollection Outputs
Streaming from Pub/Sub to BigQuery
Java/Dataflow - Unable to use ClassLoader to detect classpath elements
Writing to Google Cloud Storage from PubSub using Cloud Dataflow using DoFn
How do I write to multiple files in Apache Beam?
Diagnosing failed Cloud Dataflow pipeline
How can I improve performance of TextIO or AvroIO when reading a very large number of files?
Simple API for random access into a compressed data file