[jira] [Updated] (KAFKA-4481) Relax Kafka Streams API type constraints
[ https://issues.apache.org/jira/browse/KAFKA-4481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4481: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 2205 [https://github.com/apache/kafka/pull/2205] > Relax Kafka Streams API type constraints > > > Key: KAFKA-4481 > URL: https://issues.apache.org/jira/browse/KAFKA-4481 > Project: Kafka > Issue Type: Bug > Components: streams >Reporter: Xavier Léauté >Assignee: Xavier Léauté > Labels: kip, usability > Fix For: 0.10.2.0 > > > Streams API methods that apply transformations to streams are currently > invariant in the key and value types, when they should probably be > contravariant in those types. > For instance, {{KStream.filter(Predicatepredicate)}} should be > {{KStream.filter(Predicate predicate)}} to accept > predicates that can act on any supertype of K, or V. > Same thing applies to method that take {{Aggregator}}, {{StreamPartitioner}}, > {{KeyValueMapper}}, {{ValueMapper}}, {{ProcessorSupplier}}, {{ValueJoiner}}, > etc. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-4481) Relax Kafka Streams API type constraints
[ https://issues.apache.org/jira/browse/KAFKA-4481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4481: - Reviewer: Guozhang Wang > Relax Kafka Streams API type constraints > > > Key: KAFKA-4481 > URL: https://issues.apache.org/jira/browse/KAFKA-4481 > Project: Kafka > Issue Type: Bug > Components: streams >Reporter: Xavier Léauté >Assignee: Xavier Léauté > Labels: kip, usability > Fix For: 0.10.2.0 > > > Streams API methods that apply transformations to streams are currently > invariant in the key and value types, when they should probably be > contravariant in those types. > For instance, {{KStream.filter(Predicatepredicate)}} should be > {{KStream.filter(Predicate predicate)}} to accept > predicates that can act on any supertype of K, or V. > Same thing applies to method that take {{Aggregator}}, {{StreamPartitioner}}, > {{KeyValueMapper}}, {{ValueMapper}}, {{ProcessorSupplier}}, {{ValueJoiner}}, > etc. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-4481) Relax Kafka Streams API type constraints
[ https://issues.apache.org/jira/browse/KAFKA-4481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4481: - Labels: kip usability (was: usability) > Relax Kafka Streams API type constraints > > > Key: KAFKA-4481 > URL: https://issues.apache.org/jira/browse/KAFKA-4481 > Project: Kafka > Issue Type: Bug > Components: streams >Reporter: Xavier Léauté >Assignee: Xavier Léauté > Labels: kip, usability > Fix For: 0.10.2.0 > > > Streams API methods that apply transformations to streams are currently > invariant in the key and value types, when they should probably be > contravariant in those types. > For instance, {{KStream.filter(Predicatepredicate)}} should be > {{KStream.filter(Predicate predicate)}} to accept > predicates that can act on any supertype of K, or V. > Same thing applies to method that take {{Aggregator}}, {{StreamPartitioner}}, > {{KeyValueMapper}}, {{ValueMapper}}, {{ProcessorSupplier}}, {{ValueJoiner}}, > etc. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-4481) Relax Kafka Streams API type constraints
[ https://issues.apache.org/jira/browse/KAFKA-4481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4481: - Fix Version/s: 0.10.2.0 > Relax Kafka Streams API type constraints > > > Key: KAFKA-4481 > URL: https://issues.apache.org/jira/browse/KAFKA-4481 > Project: Kafka > Issue Type: Bug > Components: streams >Reporter: Xavier Léauté >Assignee: Xavier Léauté > Labels: kip, usability > Fix For: 0.10.2.0 > > > Streams API methods that apply transformations to streams are currently > invariant in the key and value types, when they should probably be > contravariant in those types. > For instance, {{KStream.filter(Predicatepredicate)}} should be > {{KStream.filter(Predicate predicate)}} to accept > predicates that can act on any supertype of K, or V. > Same thing applies to method that take {{Aggregator}}, {{StreamPartitioner}}, > {{KeyValueMapper}}, {{ValueMapper}}, {{ProcessorSupplier}}, {{ValueJoiner}}, > etc. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-4481) Relax Kafka Streams API type constraints
[ https://issues.apache.org/jira/browse/KAFKA-4481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xavier Léauté updated KAFKA-4481: - Status: Patch Available (was: In Progress) > Relax Kafka Streams API type constraints > > > Key: KAFKA-4481 > URL: https://issues.apache.org/jira/browse/KAFKA-4481 > Project: Kafka > Issue Type: Bug > Components: streams >Reporter: Xavier Léauté >Assignee: Xavier Léauté > Labels: usability > > Streams API methods that apply transformations to streams are currently > invariant in the key and value types, when they should probably be > contravariant in those types. > For instance, {{KStream.filter(Predicatepredicate)}} should be > {{KStream.filter(Predicate predicate)}} to accept > predicates that can act on any supertype of K, or V. > Same thing applies to method that take {{Aggregator}}, {{StreamPartitioner}}, > {{KeyValueMapper}}, {{ValueMapper}}, {{ProcessorSupplier}}, {{ValueJoiner}}, > etc. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (KAFKA-4481) Relax Kafka Streams API type constraints
[ https://issues.apache.org/jira/browse/KAFKA-4481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xavier Léauté updated KAFKA-4481: - Description: Streams API methods that apply transformations to streams are currently invariant in the key and value types, when they should probably be contravariant in those types. For instance, {{KStream.filter(Predicatepredicate)}} should be {{KStream.filter(Predicate predicate)}} to accept predicates that can act on any supertype of K, or V. Same thing applies to method that take {{Aggregator}}, {{StreamPartitioner}}, {{KeyValueMapper}}, {{ValueMapper}}, {{ProcessorSupplier}}, {{ValueJoiner}}, etc. was: Streams API methods that apply transformations to streams are currently invariant in the key and value types, when they should probably be contravariant in those types. For instance, {{KStream.filter(Predicate predicate)}} should be {{KStream.filter(Predicate predicate)}} to accept predicates that can act on any supertype of K, or V. Same thing applies to method that take {{Aggregator}}s, {{StreamPartitioner}}s, {{KeyValueMapper}}s, {{ValueMapper}}s, {{ProcessorSupplier}}s, {{ValueJoiner}}s, etc. > Relax Kafka Streams API type constraints > > > Key: KAFKA-4481 > URL: https://issues.apache.org/jira/browse/KAFKA-4481 > Project: Kafka > Issue Type: Improvement > Components: streams >Reporter: Xavier Léauté >Assignee: Xavier Léauté > Labels: usability > > Streams API methods that apply transformations to streams are currently > invariant in the key and value types, when they should probably be > contravariant in those types. > For instance, {{KStream.filter(Predicate predicate)}} should be > {{KStream.filter(Predicate predicate)}} to accept > predicates that can act on any supertype of K, or V. > Same thing applies to method that take {{Aggregator}}, {{StreamPartitioner}}, > {{KeyValueMapper}}, {{ValueMapper}}, {{ProcessorSupplier}}, {{ValueJoiner}}, > etc. -- This message was sent by Atlassian JIRA (v6.3.4#6332)