StackRating

An Elo-based rating system for Stack Overflow
Home   |   About   |   Stats and Analysis   |   Get a Badge
Rating Stats for

Reza Rokni

Rating
1503.96 (249,446th) 		Reputation
161 (530,250th)
Page: 1 2
Title Δ
Apach Beam / Dataflow transform advice 0.00
PGPy won't go on GCP Dataflow pipeline 0.00
Apache Beam Dataflow Properly Sharding and Mapping Messages from Pu... 0.00
Implementing a Streaming Cloud Dataflow transformation that calls a... 0.00
Dataflow sideinput refresh 0.00
Dataflow - distinct got stuck with 3MB of data and kills throughput +0.04
How to deserialize JSON Array to Apache beam PCollection<javaObj... 0.00
How to limit number of DoFn threads for streming job, apache beam,... 0.00
Apache Beam , how to GroupBy in a List of Objects 0.00
Best practices to use .tfrecord files for forecasting 0.00
Apache Beam - Streaming Join on Temporal Relation 0.00
Counter metrics in GCP metrics explorer 0.00
Streaming Beam pipeline with "lookbehind" 0.00
How does streaming Dataflow decide how/when to propagate elements t... +4.05
Best way to get a param into DoFn's onElement method in Apache... 0.00
How to create dataflow pipeline and auto deploy to google cloud? -4.03
How to read data from BigQuery periodically in Apache Beam? -0.00
Delay between Apache Beam FixedWindows 0.00
How to create a beam template with current date as an input (update... 0.00
Adding a timestamp to a pcollection 0.00
How to add in a new data to a TfRecord by performing a join 0.00
Feature engineering of rolling windows with apache beam 0.00
How small should be a ParDo operation for good performance and scal... 0.00
Send elements to next window under condition after triggering 0.00
Python Apache Beam, How exactly do Fixed Windows Work? -0.05
Passing variables to ParDo from outside the pipeline in Dataflow +4.00
How to make dataflow apache beam job faster 0.00
Errors trying to start ZetaSQL planner 0.00
How to split csv file based on column value in cloud dataflow pytho... 0.00
Apache Beam - What are the key concepts for writing efficient data... 0.00
How to change the event time in apache beam? 0.00
Creating complex BigQuery Schema in Google DataFlow (java) -2.12
Dataflow Distinct transform example 0.00
How to remove duplicates in sliding window - Apache Beam 0.00
IOError: Shuffle close failed: INTERNAL: RPC error: IO error: /var/... 0.00
How to refresh/reload side input on every window 0.00
@OnTimer method receives null references when fired 0.00
Pass collection to FileIO.match().filepattern() 0.00
Duplicating data across windows to fill in an indefinite number of... 0.00
Updating database with real-time windowed aggregations 0.00
For how long does Dataflow remember attribute id in PubsubIO 0.00
On-the-fly data generation for benchmarking Beam 0.00
Setting a Timer to the minimum timestamp seen 0.00
Create DAG Dataflow (apache Beam) -1.90
How can I stop the extra repetition in the return/yield, while stil... 0.00
Custom timestamp and windowing for Pub/Sub in DataFlow (Apache Beam) 0.00
Aggregating Topics with apache beam Kafkaio (Dataflow) +3.97
Difference between normal JDBC and JDBCIO connector in apache Beam? 0.00
In a batch pipeline how do I assign timestamps to data from the bat... 0.00
Accessing information (Metadata) in the file name & type in a B... 0.00