Reuven Lax created BEAM-12795:
---------------------------------

             Summary: KVs should not be needed when using schemas
                 Key: BEAM-12795
                 URL: https://issues.apache.org/jira/browse/BEAM-12795
             Project: Beam
          Issue Type: New Feature
          Components: sdk-java-core
            Reporter: Reuven Lax


When using schemas there should be no need to require a KV, as any. key or keys 
can be act as the K or a V in a KV. Users can use schemas without the need for 
KV in all cases except for state/timers DoFns, which today require that the 
input have type KV. We would like to eliminate this requirement. Users should 
be able to specify a key field extraction in their ParDo, e.g.

ParDo.of(...).withKeyFields("user.location.city"));

Or in the DoFn itself.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to