You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Ismaël Mejía (Jira)" <ji...@apache.org> on 2020/03/05 11:51:00 UTC

[jira] [Assigned] (BEAM-2479) get MAX value from PCollection .apply(Combine.globally(Max.ofDoubles()))

     [ https://issues.apache.org/jira/browse/BEAM-2479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ismaël Mejía reassigned BEAM-2479:
----------------------------------

    Assignee:     (was: Amit Sela)

> get MAX value from PCollection<Double> .apply(Combine.globally(Max.ofDoubles()))
> --------------------------------------------------------------------------------
>
>                 Key: BEAM-2479
>                 URL: https://issues.apache.org/jira/browse/BEAM-2479
>             Project: Beam
>          Issue Type: Test
>          Components: runner-spark
>            Reporter: liyuntian
>            Priority: Major
>
> PCollection<Double>  doublePCollectionValue = doublePCollection.apply(Combine.globally(Max.ofDoubles()));  
> How Can I get Max Value directly from doublePCollectionValue .
> Now I write doublePCollectionValue  to hdfs using  doublePCollectionValue .apply(TextIO.write().to(hdfsPath).withoutSharding()); Is there any method or class which I can use to get MAX value?   



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