- 0f016c8 Change dependency to be downloaded from https url by Pramod Immaneni · 5 years ago master
- 1acaf15 Remove datatorrent-3rd-party repository dependency. by Thomas Weise · 6 years ago
- 55a6abb APEXMALHAR-2260.PythonExecutionOperator Implement python code as an Apex operator by Ananth Gundabattula · 6 years ago
- 0d98d05 APEXMALHAR-2517 imports/checkstyle #662 by Apex Dev · 7 years ago
- 192d65a relocate library, contrib, benchmark, hive packages - rename files by Apex Dev · 7 years ago
- 600d435 APEXMALHAR-2034 Creating new Avro Module in contrib by SaumyaMohan · 7 years ago release-3
- c562a36 APEXMALHAR-2548 Fixed XmlParserApplicationTest test failure by Pramod Immaneni · 6 years ago
- 095a2f7 APEXMALHAR-2548 Using the correct websocket scheme when connecting to a SSL cluster by Pramod Immaneni · 7 years ago
- aa5c7c4 APEXMALHAR-2550 Made NycTaxiDataReader and NycTaxiCsvParser more resilient to data with bad format by David Yan · 6 years ago
- 934c201 APEXMALHAR-2550 use the launch machine host name for default pub/sub address. by Thomas Weise · 6 years ago
- ba830e2 Add @since tags and update change log for release 3.8.0 by Apex Dev · 7 years ago
- 9090578 Preparing for 3.9.0 development by Apex Dev · 7 years ago
- 6d298e3 APEXMALHAR-2461.Fix-dependencies-with-license-in-category-x by Ananth · 7 years ago
- 1d504ac APEXMALHAR-2547 nyc taxi example checkin by David Yan · 7 years ago
- c92c713 Merge APEXMALHAR-2544.flumetest by Ananth · 7 years ago
- c0bf0d3 APEXMALHAR-2544 Flume test synchronization bug. by Thomas Weise · 7 years ago
- be57b9f APEXMALHAR-2435 specify KeyedWindowedOperatorBenchmarkApp application name by brightchen · 7 years ago
- b247df3 APEXMALHAR-2532-TransformApplication-AlterConsoleOutputToUseFunctionOperator by Ananth · 7 years ago
- 2ef615b APEXMALHAR-2546.Mocking-dependencies-should-be-part-of-parent-pom by Ananth · 7 years ago
- 8e43bac APEXMALHAR-2542 simplify test for fast embedded execution. by Thomas Weise · 7 years ago
- d8ec173 APEXMALHAR-2542-Fix test failures by altering the location property by Ananth · 7 years ago
- 20c407b APEXMALHAR-2472.KuduInputOperator Initial implementation and addressing review comments by Thomas,Vlad and Pramod by Ananth · 7 years ago
- a725639 APEXMALHAR-2515. Added support for writing into multiple HBase tables. by Lakshmi Prasanna Velineni · 7 years ago
- 712027a APEXMALHAR-2535: change type of timeout variables from int to long by Tushar R. Gosavi · 7 years ago
- d3f7faf APEXMALHAR-2508 Add null check while calling cancel() for Timer instance in CacheManager by ajaygit158 · 7 years ago
- 6416344 APEXMALHAR-2540 Made ThrottleState serializable so that it can be serialized by Pramod Immaneni · 7 years ago
- 79567bd APEXMALHAR-2541 Fix travis-ci build by Vlad Rozov · 7 years ago
- cae29f8 APEXMALHAR-2514 JDBC poll offset rebase support. by Thomas Weise · 7 years ago
- 8321395 APEXMALHAR-2489 Change algorithm for running average by Florian Schmidt · 7 years ago
- ed3e6ff APEXMALHAR-2534 Provided fix for TopNWordsWithQueries example. by Lakshmi Prasanna Velineni · 7 years ago
- 658cafc Expand README and improve formatting. by Thomas Weise · 7 years ago
- 9ad8447 APEXMALHAR-2233 Migrate exactly-once examples. by Thomas Weise · 7 years ago
- ddbf26f Atomic file output app by Chandni Singh · 8 years ago
- 4aa3812 Use algo/UniqueCounter to reduce code by Munagala V. Ramanath · 8 years ago
- 42bfa56 Kafka to JDBC exactly-once example. by Thomas Weise · 8 years ago
- 783b7fe APEXMALHAR-2530 Refactored AbstractAppDataSnapshotServer so that subclasses don't need schemas by David Yan · 7 years ago
- cfe2458 APEXMALHAR-2500 Fix javadoc for FSInputModule by Florian Schmidt · 7 years ago
- e4e649f APEXMALHAR-2458 remove hard coded port numbers from Kafka example tests. by Thomas Weise · 7 years ago
- e778ee5 APEXMALHAR-2525 Fix yahoofinance example by Florian Schmidt · 7 years ago
- 09c4f57 APEXMALHAR-2529 Allow subclasses of AbstractFileInputOperator to have their own logic to suspend emit for the current streaming window by David Yan · 7 years ago
- 44bab44 APEXMALHAR-2513 JdbcPollInputOperator does not respect poll interval setting. (#649) by Thomas Weise · 7 years ago
- 79c3ee6 APEXMALHAR-2519 Memory fix in benchmark app properties by SaumyaMohan · 7 years ago
- b6e9dae APEXMALHAR-2526 FunctionOperator fails to resolve class from context class loader. by Thomas Weise · 7 years ago
- 99dc9b2 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 by Sandesh Hegde · 7 years ago
- b443b1a APEXMALHAR-2488 APEXMALHAR-2503 Deprecated inner join operator and ignored tests by bhupeshchawda · 7 years ago
- 54cd9b3 APEXMALHAR-2162 fix Kafka dependencies in SQL module. (#648) by Thomas Weise · 7 years ago
- 52adf3e APEXMALHAR-2518 Terminating operator execution when there is an error in commit offset processing (#644) by Pramod Immaneni · 7 years ago
- afb4252 APEXMALHAR-2434 Use fixed/settable metaQueueName in JMSTransactionableStore. Sanjay Pujare <sanjaypujare@users.noreply.github.com> is a contributing author. This closes #612. by oliverwnk · 7 years ago
- 7862fb3 APEXMALHAR-2516 contrib dependency issues by Thomas Weise · 7 years ago
- a37869e APEXMALHAR-2513 fixes for JdbcPollOperator by Thomas Weise · 7 years ago
- b42d8e7 APEXMALHAR-2459 1)Refactor the existing Kafka Input Operator. 2)Added the support of KafkaInputOperator using 0.10 consumer API by chaitanya · 7 years ago
- 4df6858 documentation fixes by Thomas Weise · 7 years ago
- df13332 APEXMALHAR-2404 Provided fixes for kryo seralization & atleast once semantics for recovery. by Lakshmi Prasanna Velineni · 7 years ago
- 0d0e448 APEXMALHAR-2397 #resolve Removing DAG.GATEWAY_CONNECT_ADDRESS which is causing evaluation failures during apex get-app-package-info call by sashadt · 7 years ago
- fc234b1 APEXMALHAR-2462 Fixed Checkstyle and Log4j Properties. by Apex Dev · 7 years ago
- 9b99e0a Fixed tests and POM.Changes related to sql connector. by Lakshmi Prasanna Velineni · 7 years ago
- eae0eee JdbcInput and HDFS output example app SPOI-8251 jdbc to jdbc app by devtagare · 7 years ago
- a1b7155 SPOI-8252 #resolve #comment Create a simple file to JDBC application by Yunhan Wang · 7 years ago
- 07869c8 APEXMALHAR-2366 Added license references, this closes #521 by Pramod Immaneni · 7 years ago
- 3c3a017 APEXMALHAR-2366 #resolve #comment Apply BloomFilter to Bucket, use internal BloomFilter by brightchen · 7 years ago
- 349be9d APEXMALHAR-2502 #FixKuduOutputOperator for extensibility by Ananth · 7 years ago
- d6f9ed5 APEXMALHAR-2494 Added description for the demo apps by chaitanya · 7 years ago
- 15e42c9 APEXMALHAR-2504 Allow for customization of TwitterSampleInput ConfigurationBuilder by Thomas Weise · 7 years ago
- 5fa5b27 APEXMALHAR-2505 retain original field order in SnapshotSchema by Thomas Weise · 7 years ago
- 59b4588 Add username/password config to jdbc operator test. by Thomas Weise · 7 years ago
- 8e44a9c APEXMALHAR-2471 Upgrading APEXCORE dependency to version 3.6.0 by ajaygit158 · 7 years ago
- 2493bcb APEXMALHAR-2492 Correct usage of empty Slice in Malhar Library by ajaygit158 · 7 years ago
- 1c902df APEXMALHAR-2491 Changes to shutdown the controller after completion of waittime in GenericFileOutputOperatorTest by ajaygit158 · 7 years ago
- 2f70751 Changed DT references to Apex by Pramod Immaneni · 7 years ago
- c48ec8c Add and test ApplicationTests & complete README by Oliver Winke · 7 years ago
- d200737 Changed package path for files to be included under malhar. Modifications to build files for project to build under malhar. by Pramod Immaneni · 7 years ago
- bb89fe9 Licensing changes to make it ready for addition into apex by Apex Dev · 7 years ago
- 2cfe153 Interceptor and hdfs test source by Chandni Singh · 7 years ago
- 4432651 Storage by gaurav · 7 years ago
- bbdab0e Flume source by Chetan Narsude · 7 years ago
- c84a2c8 Merge branch 'APEXMALHAR-2493' by Sandesh Hegde · 7 years ago
- c830f5e APEXMALHAR-2480 Fixed checkstyle and Log4j Properties. by Apex Dev · 7 years ago
- b25a128 Grouping and POM.xml changes by Lakshmi Prasanna Velineni · 7 years ago
- 41ddf61 SPOI-9236 Add example application for S3Output Module. by chaitanya · 7 years ago
- 6a617f9 SPOI-8848 S3 to HDFS example app. SPOI-10927 Example app s3 tuple output module. by yogidevendra · 7 years ago
- 118a75f APEXMALHAR-2473 Support for global cache meta information in db CacheManager by Oliver Winke · 7 years ago
- c784f4d APEXMALHAR-2493 Fixed the issue of KafkaSinglePortExactlyOnceOutputOperator going to the blocked state during recovery by chaitanya · 7 years ago
- c3f86f2 APEXMALHAR-2463 FTP input operator sample app, and documentation by francisf · 7 years ago
- 3a36298 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. by Lakshmi Prasanna Velineni · 7 years ago
- c128091 Merge branch 'APEXMALHAR-2487' of https://github.com/ilganeli/incubator-apex-malhar by priya · 7 years ago
- 3530fd9 APEXMALHAR-2487 Added support for Snappy compression in FilterStreamProvider, which in turn enables Snappy output. by Ilya Ganelin · 7 years ago
- 8eb7500 APEXMALHAR-2481 support lambda expressions with high level API by Thomas Weise · 7 years ago
- 09a65c2 APEXMALHAR-2484 Support of PartFileWriter for writing the part files by chaitanya · 7 years ago
- b5c003c APEXMALHAR-2455 Create example for Kafka 0.9 API exactly-once output by Oliver Winke · 7 years ago
- 10dd94e APEXMALHAR-2278.KuduNonTransactionalOutputOperator by Ananth · 7 years ago
- 2fe2903 APEXMALHAR-2479-regexparser-example by venkateshDT · 7 years ago
- b8ca9d6 Fixed Checkstyle and Log 4j Properties. by Apex Dev · 7 years ago
- c79def4 Grouping examples and POM and Readme changes. by Lakshmi Prasanna Velineni · 7 years ago
- 24027ed SPOI-7941 Add Kafka 0.9 example -- kafka to hdfs by Munagala V. Ramanath · 7 years ago
- a4551b4 APEXMALHAR-2476-Fix-tupleSeperator-override. by yogidevendra · 7 years ago
- 3b81350 APEXMALHAR-2431 Create Kinesis Input operator which emits byte array as a tuple by deepak-narkhede · 7 years ago
- dd80369 APEXMALHAR-2460 Redshift output module unable to emit tuples. by deepak-narkhede · 7 years ago
- 176c5ef APEXMALHAR-2426: Incorporated Regex Parser documentation review comments by venkateshDT · 7 years ago
- 42b2875 Inserted "threshold" log property in Log4j.properties file. by Lakshmi Prasanna Velineni · 7 years ago
- b60cf6e APEXMALHAR-2384 adding documentation for fixed width parser by Hitesh-Scorpio · 7 years ago