Shannon Quinn created FLINK-3626:
Summary: zipWithIndex in Python API
Key: FLINK-3626
URL: https://issues.apache.org/jira/browse/FLINK-3626
Project: Flink
Issue Type: New Feature
I'm a Python guru; if it doesn't have a Python API, I'll likely help
make one :)
Work is bad this week but I'm planning to get started on this next week!
Shannon
On 3/14/16 5:37 AM, Robert Metzger wrote:
Hi Shannon,
I'm happy to see some community engagement on our Python APIs!
On Fri, Mar
Hi Shannon,
I'm happy to see some community engagement on our Python APIs!
On Fri, Mar 11, 2016 at 6:32 PM, Chesnay Schepler
wrote:
> The subtaskIndex is not currently exposed to the python operator.
>
> Fortunately this can be changed very easily:
> On the java side, within PythonStreamer.star
The subtaskIndex is not currently exposed to the python operator.
Fortunately this can be changed very easily:
On the java side, within PythonStreamer.startPython() the python process
is started and several parameters are transferred (L.129++) using
stdin/-out.
These parameters are received on
Hi all,
I'm interested in getting involved the Python API development. The first
use-case I've encountered in my work is that of zipWithIndex, so I
started looking into how to go about implementing that. It looks like
the core of it involves being able to uniquely identify what worker
you're
