Re: Sort Accumulation

Hi Bright, I couldnot completely understand the bucketing approach you mentioned. How would we bucket the data considering we have no idea what the data will be? How about using a TreeMultiSet? Thanks, Ajay On Wed, Mar 8, 2017 at 11:24 PM, Bright Chen wrote: > Hi

[jira] [Commented] (APEXMALHAR-2386) KafkaOutput Operator: Expose the must have Kafka Properties as operator properties

[ https://issues.apache.org/jira/browse/APEXMALHAR-2386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901888#comment-15901888 ] Avneet Oberoi commented on APEXMALHAR-2386: --- Could I work on this? > KafkaOutput Operator:

[jira] [Created] (APEXMALHAR-2438) Add Azure Blob Store as a source and Sink

Avneet Oberoi created APEXMALHAR-2438: - Summary: Add Azure Blob Store as a source and Sink Key: APEXMALHAR-2438 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2438 Project: Apache Apex

[jira] [Commented] (APEXMALHAR-2435) specify KeyedWindowedOperatorBenchmarkApp application name

[ https://issues.apache.org/jira/browse/APEXMALHAR-2435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15901863#comment-15901863 ] ASF GitHub Bot commented on APEXMALHAR-2435: GitHub user brightchen reopened a pull

[GitHub] apex-malhar pull request #574: APEXMALHAR-2435 #resolve #comment specify Key...

GitHub user brightchen reopened a pull request: https://github.com/apache/apex-malhar/pull/574 APEXMALHAR-2435 #resolve #comment specify KeyedWindowedOperatorBenchm… …arkApp application name You can merge this pull request into a Git repository by running: $ git pull

[jira] [Resolved] (APEXMALHAR-2429) Ambiguity in passing "key" parameter to Join accumulation

[ https://issues.apache.org/jira/browse/APEXMALHAR-2429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar resolved APEXMALHAR-2429. --- Resolution: Done Fix Version/s: 3.7.0 > Ambiguity in passing