16e3dd850e3d682114d82f659c182096b6be3df1 b0a373b199fa061923ddefb817044f57a87e1985 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/82f204072031cf07035678fa5a9c9c1351a22de3 82f204072031cf07035678fa5a9c9c1351a22de3

2009-12-12T10:25:34-08:00

Merge remote branch 'cwensel/wip-1.0.18' into wip-1.1 Conflicts: CHANGES.txt src/core/cascading/flow/MultiMapReducePlanner.java src/core/cascading/util/Util.java src/test/cascading/CoGroupFieldedPipesTest.java version.properties 3b60e084f106e4e69d561e77a448145687c1f3cd Chris K Wensel chris@wensel.net cf0c95ded269efe35f0a00a08b677a774aa39a82 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/b0a373b199fa061923ddefb817044f57a87e1985 b0a373b199fa061923ddefb817044f57a87e1985

2009-12-11T13:23:50-08:00

Fix for NPE in c.t.h.MultiInputFormat during certain testing scenarios. Also changed proportioning to honor suggested numSplits value. 7cfc837dd5f9b8af2233b6db418bb18395a0216b Chris K Wensel chris@wensel.net 5bcb0463020c6fa7ed0d5acd3af53ca40ca6d1cf Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/cf0c95ded269efe35f0a00a08b677a774aa39a82 cf0c95ded269efe35f0a00a08b677a774aa39a82

2009-12-11T13:02:40-08:00

Fix for temp files starting with underscores (_) causing them to be ignored. 7a44cc5296b57ee8648ba961ec3b31ca96448217 Chris K Wensel chris@wensel.net efdf5b08b1abf72be891aaebc31c957fe70ff49b Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/5bcb0463020c6fa7ed0d5acd3af53ca40ca6d1cf 5bcb0463020c6fa7ed0d5acd3af53ca40ca6d1cf

2009-12-11T12:21:25-08:00

Fix for mixed types in properties object causing ClassCastExceptions. ff96d20c29c617e0fec1da795bbe657208e8c541 Chris K Wensel chris@wensel.net 10f48801e6f2e76b0c60ce61af8bf8a2f89f9f32 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/16e3dd850e3d682114d82f659c182096b6be3df1 16e3dd850e3d682114d82f659c182096b6be3df1

2009-12-09T16:03:05-08:00

fix typo 35de29c8e831e8e1e0edbfc7be661896ba68bdab Chris K Wensel chris@wensel.net 3565dba89e024c3a1a8910bb4904e2b7df20b4a7 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/10f48801e6f2e76b0c60ce61af8bf8a2f89f9f32 10f48801e6f2e76b0c60ce61af8bf8a2f89f9f32

2009-12-07T22:57:00-08:00

Added j.b.ConstructorProperties annotation to relevant class constructors. 70d11b4b95d7d08e11a5685fc0c8ce5caeb2c687 Chris K Wensel chris@wensel.net e930ad3d0fc2d5a321017e7f2bc1cb456dff8512 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/3565dba89e024c3a1a8910bb4904e2b7df20b4a7 3565dba89e024c3a1a8910bb4904e2b7df20b4a7

2009-12-04T16:49:02-08:00

refactored version numbering scheme 5ccc42d2d409184ff2c38278174a43aa6d18262f Chris K Wensel chris@wensel.net 41abbe66a8589cb4d1afd4127bb83bd6c5665177 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/e930ad3d0fc2d5a321017e7f2bc1cb456dff8512 e930ad3d0fc2d5a321017e7f2bc1cb456dff8512

2009-12-04T15:48:56-08:00

fix for delimited text scheme a77bd3ba25bffe5e558249c4d13d0c1d260c4edc Chris K Wensel chris@wensel.net 9c73d8f66e847147ca5d19fa66733c361b190316 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/41abbe66a8589cb4d1afd4127bb83bd6c5665177 41abbe66a8589cb4d1afd4127bb83bd6c5665177

2009-12-04T15:29:33-08:00

fix for npe in GlobHfs 83f0e4dac1f89c353747f7ea6b30db724342af59 Chris K Wensel chris@wensel.net 4af568894e531eea65daf9bd56048a2ad177836d Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/9c73d8f66e847147ca5d19fa66733c361b190316 9c73d8f66e847147ca5d19fa66733c361b190316

2009-12-04T15:18:20-08:00

Added new convenience method c.p.Pipe#names to return an array of all the pipe names in an assembly. 7a900400f02be59a11b14bf4ffc6745cd923f9aa Chris K Wensel chris@wensel.net 10ac35f9374c4717c39d1d4582bf7fbaf99260b5 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/4af568894e531eea65daf9bd56048a2ad177836d 4af568894e531eea65daf9bd56048a2ad177836d

2009-12-04T15:03:59-08:00

Added new c.s.Scheme type c.s.TextDelimited to allow native support for delimited text files. d34f46dbccc6a616afe18c8ad434d33b88e39f24 Chris K Wensel chris@wensel.net 9203cc62e71b46752378f072d2ca71861cb0a9e8 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/10ac35f9374c4717c39d1d4582bf7fbaf99260b5 10ac35f9374c4717c39d1d4582bf7fbaf99260b5

2009-12-04T11:54:29-08:00

updated 64f8253568f2bc6adaf550532cd15f4adea02b28 Chris K Wensel chris@wensel.net 5b8e0521f21c3bbd4814ffb2f418ef6cb642627f Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/9203cc62e71b46752378f072d2ca71861cb0a9e8 9203cc62e71b46752378f072d2ca71861cb0a9e8

2009-12-04T11:53:36-08:00

updated 8e16c1d9b08a8030b0b98776a63af90c5c61898e Chris K Wensel chris@wensel.net fd7cd1afe0685423f0c37bde5b4eb8d6c0689a67 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/5b8e0521f21c3bbd4814ffb2f418ef6cb642627f 5b8e0521f21c3bbd4814ffb2f418ef6cb642627f

2009-11-29T15:12:49-08:00

updated javadoc 308f01e017b4c8717984e2da983d5c9d7b782078 Chris K Wensel chris@wensel.net 47d388a237f153b523504b382a3c0ea4efd7b9ac Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/fd7cd1afe0685423f0c37bde5b4eb8d6c0689a67 fd7cd1afe0685423f0c37bde5b4eb8d6c0689a67

2009-11-29T15:11:31-08:00

updated javadoc b62784baba8aebc56c6254d3e601021d9309be25 Chris K Wensel chris@wensel.net 7d9bd176afdcbb557dae6c817e91b8a7dfa70b00 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/47d388a237f153b523504b382a3c0ea4efd7b9ac 47d388a237f153b523504b382a3c0ea4efd7b9ac

2009-11-28T14:34:51-08:00

Added optimization during CoGrouping where the most LHS pipe will not ever be accumulated, instead the values iterator will be used directly. d9ae0f2293f77cd3c06454e24b077c25d1c25793 Chris K Wensel chris@wensel.net 1bdea74ed2053a62970c48f01936889ebbc4b734 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/7d9bd176afdcbb557dae6c817e91b8a7dfa70b00 7d9bd176afdcbb557dae6c817e91b8a7dfa70b00

2009-11-27T11:43:01-08:00

more complex join tests 509a0d4641d55d87d2c6e86a0b7b33b705df0abd Chris K Wensel chris@wensel.net 1e89af4d88cc2f3488ece9086836c5df68a04886 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/1bdea74ed2053a62970c48f01936889ebbc4b734 1bdea74ed2053a62970c48f01936889ebbc4b734

2009-11-25T21:05:51-08:00

fixes for tests afcd1fe215d51b257a273681ed264d7d07d9deca Chris K Wensel chris@wensel.net 03f160cf0b572fd4b6f4bc0f39a1fcc292cd9744 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/1e89af4d88cc2f3488ece9086836c5df68a04886 1e89af4d88cc2f3488ece9086836c5df68a04886

2009-11-25T07:40:12-08:00

Added optimization during CoGrouping where if the lhs of the join results in a single iteration over the rhs of the join, the most rhs side stream will not be accumulated and possibly spilled. d2effb3b0c86d379bf94aaf333ed707f1713890b Chris K Wensel chris@wensel.net 7d9e46218b78387f6d71ee05909309fdb4da1244 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/03f160cf0b572fd4b6f4bc0f39a1fcc292cd9744 03f160cf0b572fd4b6f4bc0f39a1fcc292cd9744

2009-11-24T19:05:52-08:00

fix for test ffcc6f8d331c0aae21a14d3a5a579cb8e06132cb Chris K Wensel chris@wensel.net ec7b294a9de4a0c8a83a63e970b8cca2e66930f0 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/7d9e46218b78387f6d71ee05909309fdb4da1244 7d9e46218b78387f6d71ee05909309fdb4da1244

2009-11-24T18:35:04-08:00

adding partitioner a62500f00efd74a778a03148bb257377d8242d26 Chris K Wensel chris@wensel.net de9683aad3cd1e77f415444fb4416bb9d7424e50 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/ec7b294a9de4a0c8a83a63e970b8cca2e66930f0 ec7b294a9de4a0c8a83a63e970b8cca2e66930f0

2009-11-24T18:27:59-08:00

Added feature allowing c.p.CoGroup with c.p.c.Joiner to detect if a join can be satisfied, if not, the join is abandoned by discarding all the remaining values in the current group. 29f1c1cdc10d48fbd6c0f27ac6944fa38e70b7bc Chris K Wensel chris@wensel.net cb3b95b822a50340cdbf17aff04a4b86fb31e684 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/de9683aad3cd1e77f415444fb4416bb9d7424e50 de9683aad3cd1e77f415444fb4416bb9d7424e50

2009-11-24T12:31:17-08:00

log memory info on spill af4987c5ce671d7c864f50e50084d638f3b2d79c Chris K Wensel chris@wensel.net 7343146b6073599febf64f6e78a7f4ea0a5715a3 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/cb3b95b822a50340cdbf17aff04a4b86fb31e684 cb3b95b822a50340cdbf17aff04a4b86fb31e684

2009-11-23T20:39:18-08:00

2009-11-23T20:31:16-08:00

Added new counters for tuple spills and reads. Also logs grouping after first spill. e6f97f1f6613e73087cf0dd47c7c4302593f34a6 Chris K Wensel chris@wensel.net d71c4d506867817b444fb2a6cb9b895ec0d2b2ee Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/efdf5b08b1abf72be891aaebc31c957fe70ff49b efdf5b08b1abf72be891aaebc31c957fe70ff49b

2009-11-23T17:14:53-08:00

Fix for case where one side of a branch multiplexed in a mapper could step on c.t.Tuple values before being handed to the next branch. 13796803d3b4e3b4dca907238b46f630a9b4b441 Chris K Wensel chris@wensel.net 637f0f16b31d04d185e8cad57a47e3557e797d2e Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/d71c4d506867817b444fb2a6cb9b895ec0d2b2ee d71c4d506867817b444fb2a6cb9b895ec0d2b2ee

2009-11-23T14:36:01-08:00

added comment be6fb80f188ea2c35ed4fa9c678813ff5fc5bfc4 Chris K Wensel chris@wensel.net 854d348da6a58c0d8d68ea60e34ecc97b5ae8bbc Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/7343146b6073599febf64f6e78a7f4ea0a5715a3 7343146b6073599febf64f6e78a7f4ea0a5715a3

2009-11-22T08:28:18-08:00

fix for GlobHfs use in a Cascade e5c25ab40120e7cb757992587275a090275b7314 Chris K Wensel chris@wensel.net 88e88bc325c2b79c145b9615ef0e0aadba501818 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/854d348da6a58c0d8d68ea60e34ecc97b5ae8bbc 854d348da6a58c0d8d68ea60e34ecc97b5ae8bbc

2009-11-21T11:53:21-08:00

Added compression of object serialization and deserialization, on by default. 3904f5f081b6b3ae05c71318442cb06537adab24 Chris K Wensel chris@wensel.net 4889c0e0c166abb58839c3f478bac28811a2e1a4 Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/637f0f16b31d04d185e8cad57a47e3557e797d2e 637f0f16b31d04d185e8cad57a47e3557e797d2e

2009-11-14T13:20:14-08:00

Fix for edge case where Cascading jars are stored in Hadoop classpath and deserialization of c.f.Flow fails. 85bf5e8f83ae23095c4650e63810066fb70e164c Chris K Wensel chris@wensel.net 06452472ed75d22ddc12fbbead1f69a6aae2024d Chris K Wensel chris@wensel.net http://github.com/cwensel/cascading/commit/4889c0e0c166abb58839c3f478bac28811a2e1a4 4889c0e0c166abb58839c3f478bac28811a2e1a4

2009-11-14T12:57:12-08:00

Fixed bad cast of j.l.Error when caught in map/reduce pipeline stack. cc62f5150011568613471f50a46202e10d0c1a4a Chris K Wensel chris@wensel.net