apex-malhar.git
2 weeks agoRemove datatorrent-3rd-party repository dependency. master
Thomas Weise [Thu, 3 May 2018 03:56:44 +0000 (20:56 -0700)] 
Remove datatorrent-3rd-party repository dependency.

7 weeks agoAPEXMALHAR-2260.PythonExecutionOperator Implement python code as an Apex operator
Ananth Gundabattula [Wed, 7 Mar 2018 06:00:09 +0000 (17:00 +1100)] 
APEXMALHAR-2260.PythonExecutionOperator Implement python code as an Apex operator

4 months agoAPEXMALHAR-2517 imports/checkstyle #662
Apex Dev [Mon, 14 Aug 2017 13:53:10 +0000 (06:53 -0700)] 
APEXMALHAR-2517 imports/checkstyle #662

4 months agorelocate library, contrib, benchmark, hive packages - rename files
Apex Dev [Mon, 14 Aug 2017 13:38:39 +0000 (06:38 -0700)] 
relocate library, contrib, benchmark, hive packages - rename files

4 months agoAPEXMALHAR-2034 Creating new Avro Module in contrib release-3
SaumyaMohan [Wed, 13 Sep 2017 16:32:07 +0000 (12:32 -0400)] 
APEXMALHAR-2034 Creating new Avro Module in contrib

5 months agoAPEXMALHAR-2548 Fixed XmlParserApplicationTest test failure
Pramod Immaneni [Thu, 7 Dec 2017 16:56:06 +0000 (08:56 -0800)] 
APEXMALHAR-2548 Fixed XmlParserApplicationTest test failure

5 months agoAPEXMALHAR-2548 Using the correct websocket scheme when connecting to a SSL cluster
Pramod Immaneni [Wed, 25 Oct 2017 00:10:56 +0000 (17:10 -0700)] 
APEXMALHAR-2548 Using the correct websocket scheme when connecting to a SSL cluster

5 months agoAPEXMALHAR-2550 Made NycTaxiDataReader and NycTaxiCsvParser more resilient to data...
David Yan [Wed, 29 Nov 2017 04:32:46 +0000 (20:32 -0800)] 
APEXMALHAR-2550 Made NycTaxiDataReader and NycTaxiCsvParser more resilient to data with bad format

5 months agoAPEXMALHAR-2550 use the launch machine host name for default pub/sub address. 681/head
Thomas Weise [Wed, 29 Nov 2017 15:35:10 +0000 (07:35 -0800)] 
APEXMALHAR-2550 use the launch machine host name for default pub/sub address.

6 months agoAdd @since tags and update change log for release 3.8.0
Apex Dev [Sat, 4 Nov 2017 18:59:58 +0000 (05:59 +1100)] 
Add @since tags and update change log for release 3.8.0

6 months agoPreparing for 3.9.0 development
Apex Dev [Sat, 4 Nov 2017 18:35:26 +0000 (05:35 +1100)] 
Preparing for 3.9.0 development

6 months agoAPEXMALHAR-2461.Fix-dependencies-with-license-in-category-x
Ananth [Fri, 3 Nov 2017 10:38:39 +0000 (21:38 +1100)] 
APEXMALHAR-2461.Fix-dependencies-with-license-in-category-x

6 months agoAPEXMALHAR-2547 nyc taxi example checkin
David Yan [Mon, 3 Jul 2017 10:02:09 +0000 (03:02 -0700)] 
APEXMALHAR-2547 nyc taxi example checkin

6 months agoMerge APEXMALHAR-2544.flumetest
Ananth [Wed, 1 Nov 2017 09:16:25 +0000 (20:16 +1100)] 
Merge APEXMALHAR-2544.flumetest

6 months agoAPEXMALHAR-2544 Flume test synchronization bug. 677/head
Thomas Weise [Mon, 30 Oct 2017 20:19:56 +0000 (21:19 +0100)] 
APEXMALHAR-2544 Flume test synchronization bug.

7 months agoAPEXMALHAR-2435 specify KeyedWindowedOperatorBenchmarkApp application name
brightchen [Fri, 6 Oct 2017 19:04:57 +0000 (06:04 +1100)] 
APEXMALHAR-2435 specify KeyedWindowedOperatorBenchmarkApp application name

7 months agoAPEXMALHAR-2532-TransformApplication-AlterConsoleOutputToUseFunctionOperator
Ananth [Fri, 6 Oct 2017 19:04:57 +0000 (06:04 +1100)] 
APEXMALHAR-2532-TransformApplication-AlterConsoleOutputToUseFunctionOperator

7 months agoAPEXMALHAR-2546.Mocking-dependencies-should-be-part-of-parent-pom
Ananth [Thu, 5 Oct 2017 18:34:43 +0000 (05:34 +1100)] 
APEXMALHAR-2546.Mocking-dependencies-should-be-part-of-parent-pom

7 months agoAPEXMALHAR-2542 simplify test for fast embedded execution.
Thomas Weise [Sat, 30 Sep 2017 21:22:56 +0000 (14:22 -0700)] 
APEXMALHAR-2542 simplify test for fast embedded execution.

7 months agoAPEXMALHAR-2542-Fix test failures by altering the location property
Ananth [Fri, 29 Sep 2017 17:53:33 +0000 (03:53 +1000)] 
APEXMALHAR-2542-Fix test failures by altering the location property

7 months agoAPEXMALHAR-2472.KuduInputOperator Initial implementation and addressing review commen...
Ananth [Mon, 25 Sep 2017 18:14:17 +0000 (04:14 +1000)] 
APEXMALHAR-2472.KuduInputOperator Initial implementation and addressing review comments by Thomas,Vlad and Pramod

8 months agoAPEXMALHAR-2515. Added support for writing into multiple HBase tables. 638/head
Lakshmi Prasanna Velineni [Mon, 26 Jun 2017 17:57:33 +0000 (10:57 -0700)] 
APEXMALHAR-2515. Added support for writing into multiple HBase tables.

8 months agoAPEXMALHAR-2535: change type of timeout variables from int to long
Tushar R. Gosavi [Tue, 8 Aug 2017 07:03:41 +0000 (12:33 +0530)] 
APEXMALHAR-2535: change type of timeout variables from int to long
Fix NPE during teardown, when refreshtime is not set
Allow setting expiration type

8 months agoAPEXMALHAR-2508 Add null check while calling cancel() for Timer instance in CacheManager
ajaygit158 [Wed, 14 Jun 2017 06:05:06 +0000 (11:35 +0530)] 
APEXMALHAR-2508 Add null check while calling cancel() for Timer instance in CacheManager

8 months agoAPEXMALHAR-2540 Made ThrottleState serializable so that it can be serialized
Pramod Immaneni [Mon, 4 Sep 2017 03:16:49 +0000 (20:16 -0700)] 
APEXMALHAR-2540 Made ThrottleState serializable so that it can be serialized

8 months agoAPEXMALHAR-2541 Fix travis-ci build
Vlad Rozov [Tue, 5 Sep 2017 14:30:47 +0000 (07:30 -0700)] 
APEXMALHAR-2541 Fix travis-ci build

8 months agoAPEXMALHAR-2514 JDBC poll offset rebase support.
Thomas Weise [Thu, 27 Jul 2017 18:16:09 +0000 (11:16 -0700)] 
APEXMALHAR-2514 JDBC poll offset rebase support.

8 months agoAPEXMALHAR-2489 Change algorithm for running average
Florian Schmidt [Fri, 28 Jul 2017 17:46:27 +0000 (10:46 -0700)] 
APEXMALHAR-2489 Change algorithm for running average

The current algorithm for calculating the running average was subject to
a potential overflow, because part of the formula required the
average value (average) to be multiplied with the number of processed
tuples (count). average * count would for example overflow when e.g.
average > Double.MAX_VALUE and count >=2

This commit changes the formula used to the one described on
http://www.heikohoffmann.de/htmlthesis/node134.html, where such a
multiplication is not necessary anymore. It also adds a unit test which
checks that there is not overflow occuring anymore

8 months agoAPEXMALHAR-2534 Provided fix for TopNWordsWithQueries example.
Lakshmi Prasanna Velineni [Tue, 1 Aug 2017 18:26:58 +0000 (11:26 -0700)] 
APEXMALHAR-2534 Provided fix for TopNWordsWithQueries example.

9 months agoExpand README and improve formatting.
Thomas Weise [Sun, 6 Aug 2017 15:59:37 +0000 (08:59 -0700)] 
Expand README and improve formatting.

9 months agoAPEXMALHAR-2233 Migrate exactly-once examples.
Thomas Weise [Mon, 31 Jul 2017 06:51:40 +0000 (23:51 -0700)] 
APEXMALHAR-2233 Migrate exactly-once examples.

9 months agoAtomic file output app
Chandni Singh [Thu, 3 Mar 2016 02:27:15 +0000 (18:27 -0800)] 
Atomic file output app

9 months agoUse algo/UniqueCounter to reduce code
Munagala V. Ramanath [Tue, 23 Feb 2016 13:58:46 +0000 (05:58 -0800)] 
Use algo/UniqueCounter to reduce code

9 months agoKafka to JDBC exactly-once example.
Thomas Weise [Mon, 22 Feb 2016 04:42:27 +0000 (20:42 -0800)] 
Kafka to JDBC exactly-once example.

9 months agoAPEXMALHAR-2530 Refactored AbstractAppDataSnapshotServer so that subclasses don't...
David Yan [Sun, 30 Jul 2017 06:33:54 +0000 (23:33 -0700)] 
APEXMALHAR-2530 Refactored AbstractAppDataSnapshotServer so that subclasses don't need schemas

9 months agoAPEXMALHAR-2500 Fix javadoc for FSInputModule
Florian Schmidt [Fri, 28 Jul 2017 18:50:34 +0000 (11:50 -0700)] 
APEXMALHAR-2500 Fix javadoc for FSInputModule

The javadoc stated that FSInputModule is an abstract class, which it is
not. This commit fixes the JavaDoc

9 months agoAPEXMALHAR-2458 remove hard coded port numbers from Kafka example tests.
Thomas Weise [Mon, 31 Jul 2017 16:43:29 +0000 (09:43 -0700)] 
APEXMALHAR-2458 remove hard coded port numbers from Kafka example tests.

9 months agoAPEXMALHAR-2525 Fix yahoofinance example
Florian Schmidt [Tue, 18 Jul 2017 18:17:22 +0000 (11:17 -0700)] 
APEXMALHAR-2525 Fix yahoofinance example

This fixes the yahoofinance example in the malhar-examples artifact.
The StockTickInput Operator uses stock ticker symbols to fetch stock
information from the yahoo finance api. Because the default tickers
included "YHOO", which does not exist anymore, the StockTickInput
operator would crash because it fails to parse a "N/A" response from the
api into a number.

This is fixed with this commit by changing all "YHOO" tickers to "AABA",
which is the new ticker of Altaba Inc., that Yahoo is now traded under

9 months agoAPEXMALHAR-2529 Allow subclasses of AbstractFileInputOperator to have their own logic...
David Yan [Sun, 30 Jul 2017 06:14:35 +0000 (23:14 -0700)] 
APEXMALHAR-2529 Allow subclasses of AbstractFileInputOperator to have their own logic to suspend emit for the current streaming window

9 months agoAPEXMALHAR-2513 JdbcPollInputOperator does not respect poll interval setting. (#649)
Thomas Weise [Thu, 27 Jul 2017 19:03:42 +0000 (12:03 -0700)] 
APEXMALHAR-2513 JdbcPollInputOperator does not respect poll interval setting. (#649)

9 months agoAPEXMALHAR-2519 Memory fix in benchmark app properties
SaumyaMohan [Sat, 22 Jul 2017 00:38:28 +0000 (17:38 -0700)] 
APEXMALHAR-2519 Memory fix in benchmark app properties

9 months agoAPEXMALHAR-2526 FunctionOperator fails to resolve class from context class loader.
Thomas Weise [Tue, 18 Jul 2017 23:52:05 +0000 (16:52 -0700)] 
APEXMALHAR-2526 FunctionOperator fails to resolve class from context class loader.

9 months agoAPEXMALHAR-2506 Kafka Consumer Threads are responsible for reading the data from...
Sandesh Hegde [Mon, 17 Jul 2017 23:07:10 +0000 (16:07 -0700)] 
APEXMALHAR-2506 Kafka Consumer Threads are responsible for reading the data from Kafka, if those threads die, operator thread will detect and throw an exception

9 months agoAPEXMALHAR-2488 APEXMALHAR-2503 Deprecated inner join operator and ignored tests
bhupeshchawda [Mon, 29 May 2017 03:19:56 +0000 (20:19 -0700)] 
APEXMALHAR-2488 APEXMALHAR-2503 Deprecated inner join operator and ignored tests
Removed inner join example

9 months agoAPEXMALHAR-2162 fix Kafka dependencies in SQL module. (#648)
Thomas Weise [Fri, 21 Jul 2017 18:52:13 +0000 (11:52 -0700)] 
APEXMALHAR-2162 fix Kafka dependencies in SQL module. (#648)

* APEXMALHAR-2162 fix Kafka dependencies in SQL module.

* APEXMALHAR-2162 ignore flaky 0.10 tests

10 months agoAPEXMALHAR-2518 Terminating operator execution when there is an error in commit offse...
Pramod Immaneni [Fri, 14 Jul 2017 23:58:32 +0000 (16:58 -0700)] 
APEXMALHAR-2518 Terminating operator execution when there is an error in commit offset processing (#644)

10 months agoAPEXMALHAR-2434 Use fixed/settable metaQueueName in JMSTransactionableStore. Sanjay... 645/head
oliverwnk [Thu, 13 Jul 2017 06:17:37 +0000 (23:17 -0700)] 
APEXMALHAR-2434 Use fixed/settable metaQueueName in JMSTransactionableStore. Sanjay Pujare <sanjaypujare@users.noreply.github.com> is a contributing author. This closes #612.

10 months agoAPEXMALHAR-2516 contrib dependency issues 641/head
Thomas Weise [Wed, 5 Jul 2017 21:51:09 +0000 (14:51 -0700)] 
APEXMALHAR-2516 contrib dependency issues

10 months agoAPEXMALHAR-2513 fixes for JdbcPollOperator 639/head
Thomas Weise [Mon, 3 Jul 2017 00:00:34 +0000 (17:00 -0700)] 
APEXMALHAR-2513 fixes for JdbcPollOperator

Fix result set extraction to use column index.
Exit static partitions after work is done.
Propagate all exceptions from poller task.
Allow for override of DSLContext.
Add comment regarding SQL dialect support.
Fix poller example properties.
Documentation fixes.

10 months agoAPEXMALHAR-2459 1)Refactor the existing Kafka Input Operator. 2)Added the support... 600/head
chaitanya [Wed, 5 Apr 2017 10:01:47 +0000 (15:31 +0530)] 
APEXMALHAR-2459 1)Refactor the existing Kafka Input Operator. 2)Added the support of KafkaInputOperator using 0.10 consumer API

10 months agodocumentation fixes 637/head
Thomas Weise [Tue, 27 Jun 2017 02:23:02 +0000 (22:23 -0400)] 
documentation fixes

11 months agoAPEXMALHAR-2404 Provided fixes for kryo seralization & atleast once semantics for... 625/head
Lakshmi Prasanna Velineni [Thu, 18 May 2017 22:35:09 +0000 (15:35 -0700)] 
APEXMALHAR-2404 Provided fixes for kryo seralization & atleast once semantics for recovery.
Added unit test case to verify atleast once semantics for recovery.

11 months agoAPEXMALHAR-2397 #resolve Removing DAG.GATEWAY_CONNECT_ADDRESS which is causing evalua... 544/head
sashadt [Thu, 8 Jun 2017 16:47:13 +0000 (09:47 -0700)] 
APEXMALHAR-2397 #resolve Removing DAG.GATEWAY_CONNECT_ADDRESS which is causing evaluation failures during apex get-app-package-info call

11 months agoAPEXMALHAR-2462 Fixed Checkstyle and Log4j Properties. 606/head
Apex Dev [Tue, 18 Apr 2017 20:40:22 +0000 (13:40 -0700)] 
APEXMALHAR-2462 Fixed Checkstyle and Log4j Properties.

11 months agoFixed tests and POM.Changes related to sql connector.
Lakshmi Prasanna Velineni [Tue, 18 Apr 2017 17:17:19 +0000 (10:17 -0700)] 
Fixed tests and POM.Changes related to sql connector.

11 months agoJdbcInput and HDFS output example app
devtagare [Thu, 13 Apr 2017 22:59:03 +0000 (15:59 -0700)] 
JdbcInput and HDFS output example app
SPOI-8251 jdbc to jdbc app

11 months agoSPOI-8252 #resolve #comment Create a simple file to JDBC application
Yunhan Wang [Mon, 3 Apr 2017 21:58:19 +0000 (14:58 -0700)] 
SPOI-8252 #resolve #comment Create a simple file to JDBC application

11 months agoAPEXMALHAR-2366 Added license references, this closes #521 631/head
Pramod Immaneni [Thu, 1 Jun 2017 21:02:26 +0000 (14:02 -0700)] 
APEXMALHAR-2366 Added license references, this closes #521

11 months agoAPEXMALHAR-2366 #resolve #comment Apply BloomFilter to Bucket, use internal BloomFilter
brightchen [Mon, 5 Dec 2016 19:34:48 +0000 (11:34 -0800)] 
APEXMALHAR-2366 #resolve #comment Apply BloomFilter to Bucket, use internal BloomFilter

11 months agoAPEXMALHAR-2502 #FixKuduOutputOperator for extensibility 628/head
Ananth [Mon, 5 Jun 2017 20:26:31 +0000 (06:26 +1000)] 
APEXMALHAR-2502 #FixKuduOutputOperator for extensibility

11 months agoAPEXMALHAR-2494 Added description for the demo apps 623/head
chaitanya [Fri, 19 May 2017 08:38:52 +0000 (14:08 +0530)] 
APEXMALHAR-2494 Added description for the demo apps

11 months agoAPEXMALHAR-2504 Allow for customization of TwitterSampleInput ConfigurationBuilder 627/head
Thomas Weise [Sun, 28 May 2017 04:37:43 +0000 (21:37 -0700)] 
APEXMALHAR-2504 Allow for customization of TwitterSampleInput ConfigurationBuilder

11 months agoAPEXMALHAR-2505 retain original field order in SnapshotSchema 629/head
Thomas Weise [Mon, 29 May 2017 17:15:57 +0000 (10:15 -0700)] 
APEXMALHAR-2505 retain original field order in SnapshotSchema

11 months agoAdd username/password config to jdbc operator test. 624/head
Thomas Weise [Mon, 22 May 2017 04:47:55 +0000 (21:47 -0700)] 
Add username/password config to jdbc operator test.

11 months agoAPEXMALHAR-2471 Upgrading APEXCORE dependency to version 3.6.0 618/head
ajaygit158 [Tue, 25 Apr 2017 05:58:01 +0000 (11:28 +0530)] 
APEXMALHAR-2471 Upgrading APEXCORE dependency to version 3.6.0

11 months agoAPEXMALHAR-2492 Correct usage of empty Slice in Malhar Library 621/head
ajaygit158 [Wed, 17 May 2017 05:55:33 +0000 (11:25 +0530)] 
APEXMALHAR-2492 Correct usage of empty Slice in Malhar Library

11 months agoAPEXMALHAR-2491 Changes to shutdown the controller after completion of waittime in... 620/head
ajaygit158 [Tue, 16 May 2017 11:36:00 +0000 (17:06 +0530)] 
APEXMALHAR-2491 Changes to shutdown the controller after completion of waittime in GenericFileOutputOperatorTest

11 months agoChanged DT references to Apex 598/head
Pramod Immaneni [Mon, 22 May 2017 21:27:02 +0000 (14:27 -0700)] 
Changed DT references to Apex

11 months agoAdd and test ApplicationTests & complete README
Oliver Winke [Tue, 14 Mar 2017 19:12:07 +0000 (12:12 -0700)] 
Add and test ApplicationTests & complete README

11 months agoChanged package path for files to be included under malhar. Modifications to build...
Pramod Immaneni [Sun, 19 Feb 2017 18:56:00 +0000 (00:26 +0530)] 
Changed package path for files to be included under malhar. Modifications to build files for project to build under malhar.

11 months agoLicensing changes to make it ready for addition into apex
Apex Dev [Sun, 19 Feb 2017 16:31:34 +0000 (22:01 +0530)] 
Licensing changes to make it ready for addition into apex

11 months agoInterceptor and hdfs test source
Chandni Singh [Sun, 19 Feb 2017 16:04:49 +0000 (21:34 +0530)] 
Interceptor and hdfs test source

11 months agoStorage
gaurav [Sun, 19 Feb 2017 15:59:56 +0000 (21:29 +0530)] 
Storage

11 months agoFlume source
Chetan Narsude [Sun, 19 Feb 2017 15:57:29 +0000 (21:27 +0530)] 
Flume source

11 months agoMerge branch 'APEXMALHAR-2493'
Sandesh Hegde [Mon, 22 May 2017 19:30:49 +0000 (12:30 -0700)] 
Merge branch 'APEXMALHAR-2493'

12 months agoAPEXMALHAR-2480 Fixed checkstyle and Log4j Properties. 608/head
Apex Dev [Wed, 19 Apr 2017 21:07:32 +0000 (14:07 -0700)] 
APEXMALHAR-2480 Fixed checkstyle and Log4j Properties.

12 months agoGrouping and POM.xml changes
Lakshmi Prasanna Velineni [Wed, 19 Apr 2017 20:45:57 +0000 (13:45 -0700)] 
Grouping and POM.xml changes

12 months agoSPOI-9236 Add example application for S3Output Module.
chaitanya [Wed, 19 Apr 2017 04:51:12 +0000 (21:51 -0700)] 
SPOI-9236 Add example application for S3Output Module.

12 months agoSPOI-8848 S3 to HDFS example app.
yogidevendra [Wed, 19 Apr 2017 04:48:43 +0000 (21:48 -0700)] 
SPOI-8848 S3 to HDFS example app.
SPOI-10927 Example app s3 tuple output module.

12 months agoAPEXMALHAR-2473 Support for global cache meta information in db CacheManager 605/head
Oliver Winke [Mon, 17 Apr 2017 18:27:01 +0000 (11:27 -0700)] 
APEXMALHAR-2473 Support for global cache meta information in db CacheManager

  1. Uses Component interface and newly implemented CacheContext to pass properties to the Stores by calling setup(CacheContext).
  2. APEXMALHAR-2474: FSLoader implements Component to get numInitLinesToCache from CacheManager and use it in initial load.
Add implementation of get() function so data will also be loaded after initial load.
  3. APEXMALHAR-2475: CacheStore implements Component for passing readOnly and numInitLinesToCache.
Added NO_EVICTION expire strategy. This strategy will be set in setup(CacheContext) if readOnly is true.

12 months agoAPEXMALHAR-2493 Fixed the issue of KafkaSinglePortExactlyOnceOutputOperator going... 622/head
chaitanya [Thu, 18 May 2017 10:37:52 +0000 (16:07 +0530)] 
APEXMALHAR-2493 Fixed the issue of KafkaSinglePortExactlyOnceOutputOperator going to the blocked state during recovery

12 months agoAPEXMALHAR-2463 FTP input operator sample app, and documentation 596/head
francisf [Thu, 30 Mar 2017 04:27:00 +0000 (09:57 +0530)] 
APEXMALHAR-2463 FTP input operator sample app, and documentation

12 months agoAPEXMALHAR-2447 Added notfication in AbstractFileInputOperator, when scanning the... 619/head
Lakshmi Prasanna Velineni [Thu, 16 Mar 2017 15:27:39 +0000 (08:27 -0700)] 
APEXMALHAR-2447 Added notfication in AbstractFileInputOperator, when scanning the directory for first time. Implementations can use these information in different ways such as notifying downstream operators that a new directory has been scanned.

12 months agoMerge branch 'APEXMALHAR-2487' of https://github.com/ilganeli/incubator-apex-malhar
priya [Fri, 12 May 2017 08:59:35 +0000 (14:29 +0530)] 
Merge branch 'APEXMALHAR-2487' of https://github.com/ilganeli/incubator-apex-malhar

12 months agoAPEXMALHAR-2487 Added support for Snappy compression in FilterStreamProvider, which... 616/head
Ilya Ganelin [Sat, 29 Apr 2017 04:54:06 +0000 (21:54 -0700)] 
APEXMALHAR-2487 Added support for Snappy compression in FilterStreamProvider, which in turn enables Snappy output.

12 months agoAPEXMALHAR-2481 support lambda expressions with high level API 617/head
Thomas Weise [Sun, 7 May 2017 06:24:44 +0000 (23:24 -0700)] 
APEXMALHAR-2481 support lambda expressions with high level API

12 months agoAPEXMALHAR-2484 Support of PartFileWriter for writing the part files
chaitanya [Wed, 3 May 2017 09:24:03 +0000 (14:54 +0530)] 
APEXMALHAR-2484 Support of PartFileWriter for writing the part files

12 months agoAPEXMALHAR-2455 Create example for Kafka 0.9 API exactly-once output 610/head
Oliver Winke [Mon, 24 Apr 2017 23:58:54 +0000 (16:58 -0700)] 
APEXMALHAR-2455 Create example for Kafka 0.9 API exactly-once output

12 months agoAPEXMALHAR-2278.KuduNonTransactionalOutputOperator 486/head
Ananth [Wed, 3 May 2017 20:19:05 +0000 (06:19 +1000)] 
APEXMALHAR-2278.KuduNonTransactionalOutputOperator

12 months agoAPEXMALHAR-2479-regexparser-example 607/head
venkateshDT [Wed, 19 Apr 2017 07:24:52 +0000 (00:24 -0700)] 
APEXMALHAR-2479-regexparser-example

12 months agoFixed Checkstyle and Log 4j Properties. 595/head 611/head
Apex Dev [Wed, 29 Mar 2017 21:09:17 +0000 (14:09 -0700)] 
Fixed Checkstyle and Log 4j Properties.

12 months agoGrouping examples and POM and Readme changes.
Lakshmi Prasanna Velineni [Wed, 29 Mar 2017 19:46:59 +0000 (12:46 -0700)] 
Grouping examples and POM and Readme changes.

12 months agoSPOI-7941 Add Kafka 0.9 example -- kafka to hdfs
Munagala V. Ramanath [Wed, 29 Mar 2017 17:33:00 +0000 (10:33 -0700)] 
SPOI-7941 Add Kafka 0.9 example -- kafka to hdfs
SPOI-8632 Example to read from HDFS and write to Kafka -- hdfs to kafka

12 months agoAPEXMALHAR-2476-Fix-tupleSeperator-override. 603/head
yogidevendra [Thu, 6 Apr 2017 22:40:07 +0000 (15:40 -0700)] 
APEXMALHAR-2476-Fix-tupleSeperator-override.

13 months agoAPEXMALHAR-2431 Create Kinesis Input operator which emits byte array as a tuple 601/head
deepak-narkhede [Wed, 5 Apr 2017 08:21:58 +0000 (13:51 +0530)] 
APEXMALHAR-2431 Create Kinesis Input operator which emits byte array as a tuple

13 months agoAPEXMALHAR-2460 Redshift output module unable to emit tuples. 594/head
deepak-narkhede [Wed, 29 Mar 2017 11:40:44 +0000 (17:10 +0530)] 
APEXMALHAR-2460 Redshift output module unable to emit tuples.

13 months agoAPEXMALHAR-2426: Incorporated Regex Parser documentation review comments 565/head
venkateshDT [Thu, 30 Mar 2017 17:44:09 +0000 (10:44 -0700)] 
APEXMALHAR-2426: Incorporated Regex Parser documentation review comments

13 months agoInserted "threshold" log property in Log4j.properties file. 602/head
Lakshmi Prasanna Velineni [Mon, 3 Apr 2017 21:44:45 +0000 (14:44 -0700)] 
Inserted "threshold" log property in Log4j.properties file.
Fixed log4j properties.

13 months agoAPEXMALHAR-2384 adding documentation for fixed width parser 533/head
Hitesh-Scorpio [Wed, 11 Jan 2017 06:57:27 +0000 (12:27 +0530)] 
APEXMALHAR-2384 adding documentation for fixed width parser

13 months agoAPEXMALHAR-2469 Upgrade org.apache.httpcomponents.httpclient (this closes #553)
Vlad Rozov [Sat, 1 Apr 2017 15:38:13 +0000 (08:38 -0700)] 
APEXMALHAR-2469 Upgrade org.apache.httpcomponents.httpclient (this closes #553)