[
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)
