Skip to content Skip to sidebar Skip to footer
Showing posts with the label Hadoop

Read A Distributed Tab Delimited Csv

Inspired from this question, I wrote some code to store an RDD (which was read from a Parquet file)… Read more Read A Distributed Tab Delimited Csv

Loading A Defaultdict In Hadoop Using Pickle And Sys.stdin

I posted a similar question about an hour ago, but have since deleted it after realising I was aski… Read more Loading A Defaultdict In Hadoop Using Pickle And Sys.stdin

Hadoop: Output File Has Double Output

I am running a Hadoop program and have the following as my input file, input.txt: 1 2 mapper.py: i… Read more Hadoop: Output File Has Double Output

Hadoop Streaming With Python: Keeping Track Of Line Numbers

I am trying to do what should be a simple task: I need to convert a text file to upper case using H… Read more Hadoop Streaming With Python: Keeping Track Of Line Numbers

Spark Java.lang.verifyerror

I get the following error when I try to call I use python client for the spark. lines = sc.textFil… Read more Spark Java.lang.verifyerror

Running A Job Using Hadoop Streaming And Mrjob: Pipemapred.waitoutputthreads(): Subprocess Failed With Code 1

Hey I'm fairly new to the world of Big Data. I came across this tutorial on http://musicmachin… Read more Running A Job Using Hadoop Streaming And Mrjob: Pipemapred.waitoutputthreads(): Subprocess Failed With Code 1

Why Am I Getting These Strange Connection Errors When Reading Or Writing To Hadoop File System With A Python Script?

I wrote a python code to read and write to a hadoop file system with IP hdfs_ip. It takes 3 argumen… Read more Why Am I Getting These Strange Connection Errors When Reading Or Writing To Hadoop File System With A Python Script?

Hive Parseexception In Drop Table Statement

I'm using python and pyodbc module in particular to execute Hive queries on Hadoop. The portion… Read more Hive Parseexception In Drop Table Statement