I added an optional parameter to allow the user to override a tap's sink mode. This is useful when you put flows into a cascade. http://docs.cascading.org/cascading/2.1/userguide/html/ch03s08.html#N20CA7
Fix keepColsBy by passing RowVector
Merge pull request #439 from reconditesea/klin_fix_keepColsBy

Fix keepColsBy by passing RowVector
Add support for Product for converting from CTuple
Merge pull request #441 from twitter/product-converter

Merge #441
Typo
Merge pull request #443 from kevinrobinson/develop

Merge #443
Add a Sink type, fix some variance issues
Fix some issues found in test
address Kevin's comments
Merge pull request #445 from twitter/typedpipe-trait

Merge #445
Make Mode job-specific.
Fix Ryan's comment. And completely move implicit mode from Mode object to Job class. Change a bunch of other files for this change.
Remove one extra line.
Change pollinginterval to 5 to speedup test.
Address Oscar's comments.
Change pollinginterval tp 3.
Change timeout parameter in HangingTest to 3 milliseconds, since currently when this flaky test fails it always has more outputs than expected.
Change timeout in HangingTest to 2 milliseconds. Tuning this parameter for the flaky test.
Create DistributedCacheFile, a pleasant API for managing files to be distributed via hadoop's DistributedCache

Dealing with hadoop's filecache.DistributedCache is kind of awkward.
This gives users an easy way of setting up paths to be added to the
distributed cache, and hides the details of consistent-symlink-naming
and such. This is a prerequisite for loading our indexes in hadoop.