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