beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "liyuntian (JIRA)" <>
Subject [jira] [Created] (BEAM-2479) get MAX value from PCollection<Double> .apply(Combine.globally(Max.ofDoubles()))
Date Tue, 20 Jun 2017 03:45:00 GMT
liyuntian created BEAM-2479:

             Summary: get MAX value from PCollection<Double> .apply(Combine.globally(Max.ofDoubles()))
                 Key: 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

View raw message