This is an automated email from the ASF dual-hosted git repository.
mkwhit pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/crunch.git.
from 571b90c CRUNCH-678: Avoid unnecessary last modified time retrieval
new f326a63 CRUNCH-677 Source and Target accept FileSystem
new f4c1ccd CRUNCH-677 fix merge mistakes
new 88026ce Merge pull request #19 from ben-roling/CRUNCH-677_master2
The 1059 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
crunch-core/pom.xml | 6 +
.../org/apache/crunch/ExternalFilesystemIT.java | 206 +++++++++++++++++++++
.../src/main/java/org/apache/crunch/Source.java | 21 +++
.../main/java/org/apache/crunch/SourceTarget.java | 17 ++
.../src/main/java/org/apache/crunch/Target.java | 21 +++
.../java/org/apache/crunch/io/FormatBundle.java | 24 ++-
.../org/apache/crunch/io/avro/AvroFileTarget.java | 2 +-
.../org/apache/crunch/io/impl/FileSourceImpl.java | 50 ++++-
.../org/apache/crunch/io/impl/FileTargetImpl.java | 46 ++++-
.../apache/crunch/io/impl/SourceTargetImpl.java | 14 ++
.../crunch/io/parquet/AvroParquetFileTarget.java | 2 +-
.../org/apache/crunch/io/seq/SeqFileTarget.java | 4 +-
.../org/apache/crunch/io/text/TextFileTarget.java | 4 +-
.../apache/crunch/io/hbase/HBaseSourceTarget.java | 7 +
.../org/apache/crunch/io/hbase/HBaseTarget.java | 13 ++
.../crunch/io/hcatalog/HCatSourceTarget.java | 13 ++
.../org/apache/crunch/io/hcatalog/HCatTarget.java | 13 ++
.../org/apache/crunch/io/orc/OrcFileTarget.java | 2 +-
.../java/org/apache/crunch/kafka/KafkaSource.java | 13 ++
.../apache/crunch/kafka/record/KafkaSource.java | 13 ++
20 files changed, 472 insertions(+), 19 deletions(-)
create mode 100644
crunch-core/src/it/java/org/apache/crunch/ExternalFilesystemIT.java