Google Git
Sign in
apache / crunch / HEAD
  1. f75cce9 Merge pull request #34 from noslowerdna/CRUNCH-698 by Josh Wills · 3 years, 3 months ago master
  2. ee751f6 CRUNCH-698: Inclusion of local patch for AVRO-2944 by Andrew Olson · 3 years, 3 months ago
  3. a2a8796 Merge pull request #33 from ben-roling/CRUNCH-696 by Josh Wills · 4 years ago
  4. a5c5a7e Update crunch-core/src/main/java/org/apache/crunch/io/FormatBundle.java by Ben Roling · 4 years ago
  5. c57b55b CRUNCH-696 update FormatBundle.readFields() compatibility by Ben Roling · 4 years ago
  6. 807e0c8 CRUNCH-695: Fix NullPointerException in RegionLocationTable (#32) by Andrew Olson · 4 years, 1 month ago
  7. 1da1f9c Update to kafka 2.2.1 by Jan Van Besien · 4 years, 2 months ago
  8. df2ea94 Merge pull request #30 from apache/jwills_great_version_upgrade by Josh Wills · 4 years, 4 months ago
  9. fe22a6c Fixup duplicate hadoop-hdfs dep by Josh Wills · 4 years, 4 months ago jwills_great_version_upgrade
  10. 73d333e Merge pull request #31 from apache/CRUNCH-693 by Josh Wills · 4 years, 4 months ago
  11. 37be4b4 CRUNCH-693: Make text parsing locale-independent by Gabriel Reid · 4 years, 4 months ago CRUNCH-693
  12. 362853d Fix unnecessary stubbings in the kafka test suite by Josh Wills · 4 years, 6 months ago
  13. f49fa8e oops should have fixed that one by Josh Wills · 4 years, 6 months ago
  14. cd32244 mostly kafka fixes; some jackson fixes by Josh Wills · 4 years, 6 months ago
  15. 65afa91 and more more fixes by Josh Wills · 4 years, 6 months ago
  16. 7c67794 Ever more fixes by Josh Wills · 4 years, 6 months ago
  17. d94800c WIP for modernizing Crunch deps by Josh Wills · 4 years, 6 months ago
  18. fda17d0 [maven-release-plugin] prepare for next development iteration by Josh Wills · 4 years, 7 months ago
  19. 2b15eb0 [maven-release-plugin] prepare branch apache-crunch-1.0 by Josh Wills · 4 years, 7 months ago
  20. 78f1b67 Wire up crunch-kafka to work as part of the distribution/release process. by Josh Wills · 4 years, 7 months ago
  21. b58363b CRUNCH-670: Make AvroPathPerKeyTarget work with the Spark Runtime. by Josh Wills · 4 years, 8 months ago
  22. 67e2890 Merge pull request #27 from noslowerdna/CRUNCH-688 by Josh Wills · 4 years, 9 months ago
  23. 8a1c8b4 CRUNCH-688: Fix HFile node affinity for non-default namespace HBase tables by Andrew Olson · 4 years, 9 months ago
  24. f57c8fc CRUNCH-679: Improvements for usage of DistCp (#20) by Andrew Olson · 4 years, 10 months ago
  25. 587e2c9 CRUNCH-681: Updating HFileUtils to accept a filesystem parameter for … (#22) by Andrew Olson · 4 years, 10 months ago
  26. ef0c7e8 CRUNCH-685 Use whitelist and blacklist for .fileSystem() properties (#25) by Ben Roling · 4 years, 10 months ago
  27. 8711b2f CRUNCH-683 avoid unnecessary listStatus() calls from getPathSize() (#26) by Ben Roling · 4 years, 10 months ago
  28. e53004b CRUNCH-635: Output path per key for Text target by Suyash Agarwal · 4 years, 10 months ago
  29. 7c49b8b CRUNCH-684: Fix NullPointerException by Andrew Olson · 5 years ago
  30. 869aac6 CRUNCH-684: Fix .equals and .hashCode for Targets by Andrew Olson · 5 years ago
  31. a6dfa38 CRUNCH-681: Add and update javadoc by Andrew Olson · 5 years ago
  32. 31e822c CRUNCH-681: Updating HFileUtils to accept a filesystem parameter for targets and sources by Andrew Olson · 5 years ago
  33. 9b8849c Merge pull request #21 from noslowerdna/CRUNCH-680 by Micah Whitacre · 5 years ago
  34. 21cb425 CRUNCH-680: Kafka Source should split very large partitions by Andrew Olson · 5 years ago
  35. 88026ce Merge pull request #19 from ben-roling/CRUNCH-677_master2 by Micah Whitacre · 5 years ago
  36. f4c1ccd CRUNCH-677 fix merge mistakes by Ben Roling · 5 years ago
  37. f326a63 CRUNCH-677 Source and Target accept FileSystem by Ben Roling · 5 years ago
  38. 571b90c CRUNCH-678: Avoid unnecessary last modified time retrieval by Andrew Olson · 5 years ago
  39. 07458f7 CRUNCH-660, CRUNCH-675: Use DistCp instead of FileUtils.copy when source and destination paths are in different filesystems by Andrew Olson · 5 years ago
  40. 51d9443 CRUNCH-671: Failed to generate reports using "mvn site" by Jun He · 6 years ago
  41. 1b2c058 CRUNCH-619: Update to HBase 2.0.1. Contributed by Attila Sasvari. by Josh Wills · 6 years ago
  42. ffca004 CRUNCH-669: Add an option to disable temp dir deletion in the finalize() method of a DistributedPipeline by Josh Wills · 6 years ago
  43. 5ef1c4e CRUNCH-668: Support globbing patterns in From#avroFile by Clément MATHIEU · 6 years ago
  44. 4df4419 Fix HCatSourceITSpec.testBasic by Clément MATHIEU · 6 years ago
  45. 23a2da0 CRUNCH-665: Add crunch.max.poll.interval property by Clément MATHIEU · 6 years ago
  46. 6c0ae41 CRUNCH-664 Fixes HBase configuration properties being overwritten by Nathan Schile · 6 years ago
  47. 8121bdf Expose combine file split file path via Hadoop config by Ben Roling · 6 years ago
  48. 41b201a CRUNCH-662: Updated KafkaRecordReader to better handle errors, empty reads and appropriately retry by Bryan Baugher · 6 years ago
  49. 614364a CRUNCH-661: Make DataBaseSource.Builder methods public by Josh Wills · 6 years ago
  50. 8e5c2ad CRUNCH-654: KafkaSource should use the new Kafka Consumer API instead of the SimpleConsumer. Contributed by Bryan Baugher. by Josh Wills · 6 years ago
  51. 5609b01 CRUNCH-340: added HCatSource & HCatTarget by Stephen Durfey · 6 years ago
  52. 2469348 CRUNCH-659: updated hive dependency to 2.1 by Stephen Durfey · 6 years ago
  53. ae0221f CRUNCH-652: Fix to make the SourceTargetHelperTest less flakey on hadoop 3.0.0. Contributed by Gergo Repas. by Josh Wills · 7 years ago
  54. f473478 CRUNCH-653: Created KafkaSource that provides ConsumerRecord messages by Bryan Baugher · 7 years ago
  55. 28ab199 CRUNCH-647: Remove obsolete jackson dependencies by Josh Wills · 7 years ago
  56. d65ba78 CRUNCH-644 Supply preferred node for HFile writes by Gabriel Reid · 7 years ago
  57. 047d8fd CRUNCH-618: Run on Spark 2. Contributed by Gergő Pásztor. by Tom White · 7 years ago
  58. ce9aaa3 CRUNCH-642 Enable GroupingOptions for Distinct operations. by Xavier Talpe · 7 years ago
  59. afc171f CRUNCH-641: Wrong decimal format in dot files. Contributed by Gergő Pásztor. by Tom White · 7 years ago
  60. d5e40e3 CRUNCH-642 Enable numReducers option for Distinct operations. by Xavier Talpe · 7 years ago
  61. ca8ff16 CRUNCH-636: amend Make replication factor for temporary files configurable by Attila Sasvari · 7 years ago
  62. e176b61 CRUNCH-636: Make replication factor for temporary files configurable by Attila Sasvari · 7 years ago
  63. e520d9f CRUNCH-638: Improve dot file generation for better supportability. Contributed by Gergő Pásztor. by Tom White · 7 years ago
  64. e3ba6fc CRUNCH-633: Remove the commons-httpclient:commons-httpclient dependency. Contributed by Gergő Pásztor. by Tom White · 7 years ago
  65. cde71cf CRUNCH-634 Fix typo in log message by Gabriel Reid · 7 years ago
  66. a743e4e CRUNCH-628: Upgraded to Kafka 0.10.0.x by Micah Whitacre · 7 years ago
  67. 427c54a [maven-release-plugin] prepare for next development iteration by Josh Wills · 7 years ago
  68. d9a7099 [maven-release-plugin] prepare branch apache-crunch-0.15 by Josh Wills · 7 years ago
  69. 049fb49 CRUNCH-632: Added support for compressed CSVSource files. by Micah Whitacre · 7 years ago
  70. 2e47294 Merge branch 'CRUNCH-630' by Micah Whitacre · 7 years ago
  71. 6280983 CRUNCH-629: Kafka source pulling is aggressive by Brian Tieman · 7 years ago
  72. 6cb3cb0 CRUNCH-630: set a better default for the situation where offsets are out of range. by Micah Whitacre · 7 years ago
  73. 901d064 Quick and Dirty Workaround for Crunch DistCache by Dimitry Goldin · 8 years ago
  74. c14acfa CRUNCH-622: From.avroFile fails if path not on default filesystem. Contributed by Micah Whitacre. by Josh Wills · 7 years ago
  75. fbda02f CRUNCH-620: Reduce "isn't a known config" warnings by slimming down ConsumerConfig properties by Stefan Mendoza · 8 years ago
  76. e929e04 CRUNCH-625: Add missing .union implementations for LTables with LTables and PTables by David Whiting · 8 years ago
  77. ef8d60f CRUNCH-621: Added check into hasPendingData to check if there is a large number of requests with no data to make sure there is still data there. by Micah Whitacre · 8 years ago
  78. 5944f81 CRUNCH-623: Improves Javadoc of PTable#cogroup by Nathan Schile · 8 years ago
  79. e8d2a69 CRUNCH-617: Support defensively handling null when partition leader cannot be found. by Micah Whitacre · 8 years ago
  80. 5d237b3 CRUNCH-616: Replace (possibly copyrighted) Maugham text with Dickens. Contributed by Sean Owen. by Tom White · 8 years ago
  81. f1d074c CRUNCH-601: Handle empty PCollections correctly in Crunch-on-Spark. Created by Micah Whitacre, by Josh Wills · 8 years ago
  82. 3fff74e CRUNCH-519: Add more detail to plan dot file. Contributed by Ron Hashimshony. by Josh Wills · 8 years ago
  83. 0b19717 CRUNCH-604: Avoid expensive Writables.reloadWritableComparableCodes by Micah Whitacre · 8 years ago
  84. 597eadd CRUNCH-611: Corrected files that were missing the APL headers. by Micah Whitacre · 8 years ago
  85. 157ae25 CRUNCH-611: Added API for Offset reading/writing along with a simple implementation that supports doing it from hdfs. by Micah Whitacre · 8 years ago
  86. b0491f2 CRUNCH-614: Fix HFileUtils.writeToHFilesForIncrementalLoad slowed dramatically by copying KeyValue byte array. Contributed by Ben Roling. by Josh Wills · 8 years ago
  87. 8ca28db CRUNCH-613: Fix FileTargetImplTest.testHandleOutputsMovesFilesToDestination instability by Clément MATHIEU · 8 years ago
  88. 983019a CRUNCH-612: Add support of private ctors to AvroDeepCopier by Clément MATHIEU · 8 years ago
  89. fb21800 CRUNCH-609: Improved KafkaRecordReader to keep retrying when the range of offsets has not been fully consumed. by Micah Whitacre · 8 years ago
  90. 360d72a CRUNCH-606: Handle setting version correctly and removed stray System.out in test. by Micah Whitacre · 8 years ago
  91. 321cfef CRUNCH-606: Kafka Source for Crunch which supports reading data as BytesWritable by Micah Whitacre · 8 years ago
  92. c09c4ee CRUNCH-608 Write Bloom filters in HFiles by Gabriel Reid · 8 years ago
  93. 49e4575 CRUNCH-607 Allow collection reuse in MemPipeline by Gabriel Reid · 8 years ago
  94. 49a64ab [maven-release-plugin] prepare for next development iteration by Josh Wills · 8 years ago
  95. 973c70d [maven-release-plugin] prepare branch apache-crunch-0.14 by Josh Wills · 8 years ago
  96. 2a72ef1 CRUNCH-579: Supported access to counters from original TaskContext by mkwhitacre · 8 years ago
  97. 02828f8 CRUNCH-600: pass job credentials when building multiple outputs by Igor Bernstein · 8 years ago
  98. 65f3919 CRUNCH-599: Fix increment and incrementIf methods in crunch-lambda so they also emit the incoming element by David Whiting · 8 years ago
  99. 1252e7f CRUNCH-597: Upgrade to Parquet 1.8.1 by Josh Wills · 8 years ago
  100. 0d31415 CRUNCH-596 Support right-outer bloom join by tworec · 8 years ago