Hi Apex Dev community,
Kindly provide with feedback if any for the following approach for
implementing S3RecordReader.
*S3RecordReader(delimited records)*
*Input *: BlockMetaData containing offset and length
*Expected Output :* Records in the block
*Approach : *
Similar to approach currently bein
[
https://issues.apache.org/jira/browse/APEXMALHAR-2263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved APEXMALHAR-2263.
--
Resolution: Fixed
Fix Version/s: 3.6.0
> Offsets in AbstractFileInputOperato
[
https://issues.apache.org/jira/browse/APEXMALHAR-2263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15587803#comment-15587803
]
ASF GitHub Bot commented on APEXMALHAR-2263:
Github user asfgit closed th
Github user asfgit closed the pull request at:
https://github.com/apache/apex-malhar/pull/456
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Very nice ..:)
I would like to contribute as well.
Thanks,
Chinmay.
On Tue, Oct 18, 2016 at 2:19 AM, David Yan wrote:
> I would also like to contribute. Thanks!
>
> David
>
> On Mon, Oct 17, 2016 at 10:01 AM, Thomas Weise wrote:
>
> > FYI, the first cut of Apex runner for Beam is in a feature
Deepak Narkhede created APEXMALHAR-2308:
---
Summary: BlockReader must consider fixed width length in emitted
block alignment.
Key: APEXMALHAR-2308
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2308
[
https://issues.apache.org/jira/browse/APEXMALHAR-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15587668#comment-15587668
]
ASF GitHub Bot commented on APEXMALHAR-2190:
GitHub user brightchen reope
[
https://issues.apache.org/jira/browse/APEXMALHAR-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15587667#comment-15587667
]
ASF GitHub Bot commented on APEXMALHAR-2190:
Github user brightchen close
Github user brightchen closed the pull request at:
https://github.com/apache/apex-malhar/pull/404
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the featur
GitHub user brightchen reopened a pull request:
https://github.com/apache/apex-malhar/pull/404
APEXMALHAR-2190 #resolve #comment Use reusable buffer to serial spillâ¦
â¦able data structure
You can merge this pull request into a Git repository by running:
$ git pull https://gi
[
https://issues.apache.org/jira/browse/APEXMALHAR-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ajay Gupta reassigned APEXMALHAR-2303:
--
Assignee: Ajay Gupta
> S3 Line By Line Module
> --
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated APEXMALHAR-2306:
-
Summary: Tests should allow for additions to OperatorContext interface
(was: malhar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15587351#comment-15587351
]
Thomas Weise commented on APEXMALHAR-2306:
--
Have a look at FSInputModuleTest
[
https://issues.apache.org/jira/browse/APEXMALHAR-2307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan updated APEXMALHAR-2307:
--
Description: The code does not remove any windows from the keyToWindows
map. It should over
David Yan created APEXMALHAR-2307:
-
Summary: Session windows are not deleted properly after merge or
extend in InMemorySessionWindowedStorage
Key: APEXMALHAR-2307
URL: https://issues.apache.org/jira/browse/APEXMAL
[
https://issues.apache.org/jira/browse/APEXMALHAR-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15587143#comment-15587143
]
ASF GitHub Bot commented on APEXMALHAR-2306:
Github user sanjaypujare clo
Github user sanjaypujare closed the pull request at:
https://github.com/apache/apex-malhar/pull/459
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feat
[
https://issues.apache.org/jira/browse/APEXMALHAR-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vlad Rozov updated APEXMALHAR-2306:
---
Description:
While trying to build/test malhar against the latest apex-core, the followin
[
https://issues.apache.org/jira/browse/APEXMALHAR-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15587040#comment-15587040
]
ASF GitHub Bot commented on APEXMALHAR-2306:
GitHub user sanjaypujare ope
GitHub user sanjaypujare opened a pull request:
https://github.com/apache/apex-malhar/pull/459
APEXMALHAR-2306 fix OperatorContext implementations to add the new
required method
@vrozov these changes were required to run malhar successfully against
latest apex-core. This is just
Sanjay M Pujare created APEXMALHAR-2306:
---
Summary: malhar unit test(s) have a dependency on OperatorContext
in apex-core
Key: APEXMALHAR-2306
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2306
[
https://issues.apache.org/jira/browse/APEXMALHAR-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15586908#comment-15586908
]
ASF GitHub Bot commented on APEXMALHAR-2305:
GitHub user davidyan74 opene
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/458
APEXMALHAR-2305 #resolve Mirror the proto-session window behavior desâ¦
â¦cribed in the streaming 102 blog
@siyuanh please review and merge
You can merge this pull request into a
David Yan created APEXMALHAR-2305:
-
Summary: Change implementation of session window to reflect what
is described in streaming 102 blog
Key: APEXMALHAR-2305
URL: https://issues.apache.org/jira/browse/APEXMALHAR-23
[
https://issues.apache.org/jira/browse/APEXCORE-561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15586503#comment-15586503
]
David Yan commented on APEXCORE-561:
This is a good feature to have to diagnostics.
[
https://issues.apache.org/jira/browse/APEXMALHAR-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chandni Singh resolved APEXMALHAR-2299.
---
Resolution: Fixed
> TimeBasedDedupOperator throws exception during time bucket as
[
https://issues.apache.org/jira/browse/APEXCORE-510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15586280#comment-15586280
]
ASF GitHub Bot commented on APEXCORE-510:
-
GitHub user sanjaypujare opened a pul
GitHub user sanjaypujare opened a pull request:
https://github.com/apache/apex-core/pull/411
APEXCORE-510 Implement check in DefaultOutputPort for thread affinity
between setup and emit
@vrozov pls review and merge as appropriate
You can merge this pull request into a Git reposit
[
https://issues.apache.org/jira/browse/APEXMALHAR-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15586277#comment-15586277
]
ASF GitHub Bot commented on APEXMALHAR-2299:
Github user asfgit closed th
Github user asfgit closed the pull request at:
https://github.com/apache/apex-malhar/pull/454
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Chinmay Kolhatkar created APEXMALHAR-2304:
-
Summary: Apex SQL: Add examples for SQL in Apex in demos folder
Key: APEXMALHAR-2304
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2304
Proje
[
https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585751#comment-15585751
]
Chandni Singh edited comment on APEXMALHAR-2284 at 10/18/16 3:40 PM:
--
[
https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585751#comment-15585751
]
Chandni Singh commented on APEXMALHAR-2284:
---
One concept that I think I sho
Github user yogidevendra closed the pull request at:
https://github.com/apache/apex-malhar/pull/439
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feat
[
https://issues.apache.org/jira/browse/APEXMALHAR-2272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585644#comment-15585644
]
ASF GitHub Bot commented on APEXMALHAR-2272:
Github user yogidevendra clo
[
https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585604#comment-15585604
]
Bhupesh Chawda commented on APEXMALHAR-2284:
As far as I understand, the
GitHub user deepak-narkhede reopened a pull request:
https://github.com/apache/apex-malhar/pull/457
APEXMALHAR 2302 Add blockSize property to FSRecordReaderModule
This change adds blockSize property from FileSplitter to
FSRecordReaderModule.
Tested with RecordReader Application.
Github user deepak-narkhede closed the pull request at:
https://github.com/apache/apex-malhar/pull/457
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the f
Ajay Gupta created APEXMALHAR-2303:
--
Summary: S3 Line By Line Module
Key: APEXMALHAR-2303
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2303
Project: Apache Apex Malhar
Issue Type: B
39 matches
Mail list logo
