You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "liyuntian (JIRA)" <ji...@apache.org> on 2017/06/20 03:45:00 UTC

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

liyuntian created BEAM-2479:
-------------------------------

             Summary: 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
            Assignee: Amit Sela


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
(v6.4.14#64029)