Re: Reading CSV with multiLine option invalidates encoding option.

2017-08-17 Thread Han-Cheol Cho
e info. > > > On Wed, Aug 16, 2017 at 2:54 PM, Han-Cheol Cho <prian...@gmail.com> wrote: > >> My apologies, >> >> It was a problem of our Hadoop cluster. >> When we tested the same code on another cluster (HDP-based), it worked >> without any problem. >

Re: Reading CSV with multiLine option invalidates encoding option.

2017-08-15 Thread Han-Cheol Cho
でやってみよう| +--+ spark.read.option("encoding", "sjis").option("multiLine", true).csv("b.txt").show(1) +--+ | _c0| +--+ |8月データだけでやってみよう| +------+ ``` I am still digging the root cause and will share it later :-) Best

Reading CSV with multiLine option invalidates encoding option.

2017-08-15 Thread Han-Cheol Cho
; file.start == 0 UnivocityParser.parseIterator(lines, shouldDropHeader, parser, schema) } It seems like a bug. Is there anyone who had the same problem before? Best wishes, Han-Cheol -- == Han-Cheol Cho, Ph.D. Data scientist, Data Science Team, Data Laboratory NH

strange usage of tempfile.mkdtemp() in PySpark mllib.recommendation doctest

2017-03-02 Thread Han-Cheol Cho
in HDFS. After all, the doctest removes only LOCAL temp directory using shutil.rmtree(). Shouldn't we delete the temporary directory in HDFS too? Best wishes, HanCheol Han-Cheol Cho Data Laboratory / Data Scientist 〒160-0022 東京都新宿区新宿6-27-30 新宿イーストサイドスクエア13階 Email hancheol@nhn-techorus.com

A question about inconsistency during dataframe creation with RDD/dict in PySpark

2017-02-01 Thread Han-Cheol Cho
.show() +++ | k1| k2| +++ |v1.1|v1.2| |v2.1|null| +++ urdd.toDF().show() +++ | k1| k2| +++ |v1.1|v1.2| |v2.1|null| +----+----+ I am wonder whether this dif

null values returned by max() over a window function

2016-11-28 Thread Han-Cheol Cho
Tablet 6500 null+--+--+---+---+As you can see, the last column calculates the max value among the current row,left two rows and right two rows partitioned by category row.However, the result for the last two rows in each category partition is null.Is th