AUTHORS
LICENSE
MANIFEST.in
README.md
VERSION
pydoop.properties
requirements.txt
setup.cfg
setup.py
docs/Makefile
docs/conf.py
docs/how_to_cite.rst
docs/index.rst
docs/installation.rst
docs/pydoop_script.rst
docs/pydoop_script_options.rst
docs/pydoop_submit_options.rst
docs/running_pydoop_applications.rst
docs/self_contained.rst
docs/_build/.gitignore
docs/_static/crs4.png
docs/_templates/layout.html
docs/api_docs/hadut.rst
docs/api_docs/hdfs_api.rst
docs/api_docs/index.rst
docs/api_docs/mr_api.rst
docs/examples/avro.rst
docs/examples/index.rst
docs/examples/input_format.rst
docs/examples/intro.rst
docs/examples/sequence_file.rst
docs/news/archive.rst
docs/news/index.rst
docs/news/latest.rst
docs/tutorial/hdfs_api.rst
docs/tutorial/index.rst
docs/tutorial/mapred_api.rst
docs/tutorial/pydoop_script.rst
examples/README
examples/config.sh
examples/run_all
examples/avro/build.sh
examples/avro/config.sh
examples/avro/pom.xml
examples/avro/run
examples/avro/run_avro_container_in
examples/avro/run_avro_container_in_out
examples/avro/run_avro_parquet_in
examples/avro/run_avro_parquet_in_out
examples/avro/run_avro_pyrw
examples/avro/run_color_count
examples/avro/run_kmer_count
examples/avro/write_avro_kv
examples/avro/data/mini_aligned_seqs.gz.parquet
examples/avro/py/avro_base.py
examples/avro/py/avro_container_dump_results.py
examples/avro/py/avro_key_in.py
examples/avro/py/avro_key_in_out.py
examples/avro/py/avro_key_value_in.py
examples/avro/py/avro_key_value_in_out.py
examples/avro/py/avro_parquet_dump_results.py
examples/avro/py/avro_pyrw.py
examples/avro/py/avro_value_in.py
examples/avro/py/avro_value_in_out.py
examples/avro/py/check_cc.py
examples/avro/py/check_results.py
examples/avro/py/color_count.py
examples/avro/py/create_input.py
examples/avro/py/gen_data.py
examples/avro/py/generate_avro_users.py
examples/avro/py/kmer_count.py
examples/avro/py/show_kmer_count.py
examples/avro/py/write_avro.py
examples/avro/schemas/alignment_record.avsc
examples/avro/schemas/alignment_record_proj.avsc
examples/avro/schemas/pet.avsc
examples/avro/schemas/stats.avsc
examples/avro/schemas/user.avsc
examples/avro/src/main/java/it/crs4/pydoop/WriteKV.java
examples/avro/src/main/java/it/crs4/pydoop/WriteParquet.java
examples/c++/HadoopPipes.cc
examples/c++/Makefile
examples/c++/README.txt
examples/c++/SerialUtils.cc
examples/c++/StringUtils.cc
examples/c++/wordcount.cc
examples/c++/include/hadoop/Pipes.hh
examples/c++/include/hadoop/SerialUtils.hh
examples/c++/include/hadoop/StringUtils.hh
examples/c++/include/hadoop/TemplateFactory.hh
examples/hdfs/common.py
examples/hdfs/repl_session.py
examples/hdfs/run
examples/hdfs/treegen.py
examples/hdfs/treewalk.py
examples/input/alice_1.txt
examples/input/alice_2.txt
examples/input_format/check_results.py
examples/input_format/run
examples/input_format/it/crs4/pydoop/mapred/TextInputFormat.java
examples/input_format/it/crs4/pydoop/mapreduce/TextInputFormat.java
examples/pydoop_script/check.py
examples/pydoop_script/run
examples/pydoop_script/run_script.sh
examples/pydoop_script/data/stop_words.txt
examples/pydoop_script/data/base_histogram_input/example_1.sam
examples/pydoop_script/data/base_histogram_input/example_2.sam
examples/pydoop_script/data/transpose_input/matrix.txt
examples/pydoop_script/scripts/base_histogram.py
examples/pydoop_script/scripts/caseswitch.py
examples/pydoop_script/scripts/grep.py
examples/pydoop_script/scripts/lowercase.py
examples/pydoop_script/scripts/transpose.py
examples/pydoop_script/scripts/wc_combiner.py
examples/pydoop_script/scripts/wordcount.py
examples/pydoop_script/scripts/wordcount_sw.py
examples/pydoop_submit/check.py
examples/pydoop_submit/run
examples/pydoop_submit/run_submit.sh
examples/pydoop_submit/data/cols_1.txt
examples/pydoop_submit/data/cols_2.txt
examples/pydoop_submit/mr/map_only_java_writer.py
examples/pydoop_submit/mr/map_only_python_writer.py
examples/pydoop_submit/mr/nosep.py
examples/pydoop_submit/mr/wordcount_full.py
examples/pydoop_submit/mr/wordcount_minimal.py
examples/self_contained/check_results.py
examples/self_contained/run
examples/self_contained/vowelcount/__init__.py
examples/self_contained/vowelcount/lib/__init__.py
examples/self_contained/vowelcount/mr/__init__.py
examples/self_contained/vowelcount/mr/main.py
examples/self_contained/vowelcount/mr/mapper.py
examples/self_contained/vowelcount/mr/reducer.py
examples/sequence_file/check.py
examples/sequence_file/run
examples/sequence_file/bin/filter.py
examples/sequence_file/bin/wordcount.py
lib/avro-mapred-1.7.7-hadoop2.jar
pydoop/__init__.py
pydoop/avrolib.py
pydoop/hadoop_utils.py
pydoop/hadut.py
pydoop/jc.py
pydoop/test_support.py
pydoop/test_utils.py
pydoop.egg-info/PKG-INFO
pydoop.egg-info/SOURCES.txt
pydoop.egg-info/dependency_links.txt
pydoop.egg-info/entry_points.txt
pydoop.egg-info/not-zip-safe
pydoop.egg-info/requires.txt
pydoop.egg-info/top_level.txt
pydoop/app/__init__.py
pydoop/app/argparse_types.py
pydoop/app/main.py
pydoop/app/script.py
pydoop/app/script_template.py
pydoop/app/submit.py
pydoop/hdfs/__init__.py
pydoop/hdfs/common.py
pydoop/hdfs/file.py
pydoop/hdfs/fs.py
pydoop/hdfs/path.py
pydoop/hdfs/core/__init__.py
pydoop/mapreduce/__init__.py
pydoop/mapreduce/api.py
pydoop/mapreduce/binary_protocol.py
pydoop/mapreduce/connections.py
pydoop/mapreduce/pipes.py
pydoop/utils/__init__.py
pydoop/utils/conversion_tables.py
pydoop/utils/jvm.py
pydoop/utils/misc.py
pydoop/utils/py3compat.py
src/Py_macros.h
src/buf_macros.h
src/py3k_compat.h
src/it/crs4/pydoop/NoSeparatorTextOutputFormat.java
src/it/crs4/pydoop/mapreduce/pipes/Application.java
src/it/crs4/pydoop/mapreduce/pipes/BinaryProtocol.java
src/it/crs4/pydoop/mapreduce/pipes/DownwardProtocol.java
src/it/crs4/pydoop/mapreduce/pipes/DummyRecordReader.java
src/it/crs4/pydoop/mapreduce/pipes/OpaqueSplit.java
src/it/crs4/pydoop/mapreduce/pipes/OutputHandler.java
src/it/crs4/pydoop/mapreduce/pipes/PipesMapper.java
src/it/crs4/pydoop/mapreduce/pipes/PipesNonJavaInputFormat.java
src/it/crs4/pydoop/mapreduce/pipes/PipesNonJavaOutputFormat.java
src/it/crs4/pydoop/mapreduce/pipes/PipesPartitioner.java
src/it/crs4/pydoop/mapreduce/pipes/PipesReducer.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroBridgeKeyReader.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroBridgeKeyValueReader.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroBridgeKeyValueWriter.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroBridgeKeyWriter.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroBridgeReaderBase.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroBridgeValueReader.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroBridgeValueWriter.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroBridgeWriterBase.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroInputBridgeBase.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroInputKeyBridge.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroInputKeyValueBridge.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroInputValueBridge.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroKeyInputFormat.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroKeyOutputFormat.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroKeyRecordReader.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroKeyRecordWriter.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroKeyValueInputFormat.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroKeyValueOutputFormat.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroKeyValueRecordReader.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroKeyValueRecordWriter.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroOutputBridgeBase.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroOutputFormatBase.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroOutputKeyBridge.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroOutputKeyValueBridge.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroOutputValueBridge.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroRecordReaderBase.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroRecordWriterBase.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroValueInputFormat.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroValueOutputFormat.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroValueRecordReader.java
src/it/crs4/pydoop/mapreduce/pipes/PydoopAvroValueRecordWriter.java
src/it/crs4/pydoop/mapreduce/pipes/Submitter.java
src/it/crs4/pydoop/mapreduce/pipes/TaskLog.java
src/it/crs4/pydoop/mapreduce/pipes/TaskLogAppender.java
src/it/crs4/pydoop/mapreduce/pipes/UpwardProtocol.java
src/libhdfs/config.h
src/libhdfs/exception.c
src/libhdfs/exception.h
src/libhdfs/hdfs.c
src/libhdfs/jni_helper.c
src/libhdfs/jni_helper.h
src/libhdfs/common/htable.c
src/libhdfs/common/htable.h
src/libhdfs/include/hdfs/hdfs.h
src/libhdfs/os/mutexes.h
src/libhdfs/os/thread.h
src/libhdfs/os/thread_local_storage.h
src/libhdfs/os/posix/mutexes.c
src/libhdfs/os/posix/platform.h
src/libhdfs/os/posix/thread.c
src/libhdfs/os/posix/thread_local_storage.c
src/libhdfs/os/windows/inttypes.h
src/libhdfs/os/windows/mutexes.c
src/libhdfs/os/windows/platform.h
src/libhdfs/os/windows/thread.c
src/libhdfs/os/windows/thread_local_storage.c
src/libhdfs/os/windows/unistd.h
src/native_core_hdfs/hdfs_file.cc
src/native_core_hdfs/hdfs_file.h
src/native_core_hdfs/hdfs_fs.cc
src/native_core_hdfs/hdfs_fs.h
src/native_core_hdfs/hdfs_module.cc
src/sercore/hu_extras.cpp
src/sercore/hu_extras.h
src/sercore/sercore.cpp
src/sercore/streams.cpp
src/sercore/streams.h
src/sercore/HadoopUtils/SerialUtils.cc
src/sercore/HadoopUtils/SerialUtils.hh
test/__init__.py
test/all_tests.py
test/app/__init__.py
test/app/all_tests.py
test/app/test_submit.py
test/avro/all_tests.py
test/avro/common.py
test/avro/test_io.py
test/avro/user.avsc
test/common/__init__.py
test/common/all_tests.py
test/common/test_hadoop_utils.py
test/common/test_hadut.py
test/common/test_pydoop.py
test/common/test_test_support.py
test/hdfs/__init__.py
test/hdfs/all_tests.py
test/hdfs/common_hdfs_tests.py
test/hdfs/test_common.py
test/hdfs/test_core.py
test/hdfs/test_hdfs.py
test/hdfs/test_hdfs_fs.py
test/hdfs/test_local_fs.py
test/hdfs/test_path.py
test/hdfs/try_hdfs.py
test/mapreduce/__init__.py
test/mapreduce/all_tests.py
test/mapreduce/m_task.cmd
test/mapreduce/r_task.cmd
test/mapreduce/test_connections.py
test/mapreduce/test_opaque.py
test/mapreduce/it/crs4/pydoop/mapreduce/pipes/OpaqueRoundtrip.java
test/sercore/all_tests.py
test/sercore/test_deser.py
test/sercore/test_streams.py