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