About balakumar_b05

balakumar_b05 · ‎05-12-2017

Based on the columns in spark dataframe need to do a lookup on another huge HBASE table. Is there any efficient way available to perform lookup operation in Spark Dataframe

balakumar_b05 · ‎05-12-2017

Using spark accumulable collection can we able to accumulate data streaming in different kakfa events.

balakumar_b05 · ‎05-12-2017

Why RDD looks to be faster on certain operations like filter compared to DataFrame.

balakumar_b05 · ‎05-05-2017

In spark streaming, how to load data received in different events into collection. Lets say on event 1, 1000 records are streamed and on event 2 again another 1000 records are streamed. Now at the end of event 2 I want both the event data (1000 + 1000) I tried accumulable collection in spark to accumulate data streamed in different events. But, it did not work. Please help.

balakumar_b05 · ‎04-25-2017

I want to improve the performance of HBase Read operation. Is there any option available in spark hbase connector to scale up the hbase read operation?

balakumar_b05 · ‎04-25-2017

We are working on 5 node system.

balakumar_b05 · ‎04-25-2017

Need a solution for the below scenario: Let say 3 million records are stored in HBASE which is a past data. Now on streaming let say 10k records have been pulled and for those 10k records need to get its matching records from HBASE based on the key and the operation should complete in less than a half a minute. We are using Spark HBASE connector.

balakumar_b05 · ‎03-13-2017

val cat = s"""{ |"table":{"namespace":"myTable", "name":"person", "tableCoder":"PrimitiveType"}, |"rowkey":"ROW", |"columns":{ |"col0":{"cf":"person", "col":"detail", "type":"string"} |} |}""".stripMargin Here("col0":{"cf":"person", "col":"detail", "type":"string"}) you were missing the rowkey details. For example: see here, id column is pointed to HBASE rowkey "id":{"cf":"rowkey", "col":"key", "type":"string"},

balakumar_b05 · ‎02-23-2017

I tried to follow the same steps mentioned above to override the log4j properties but still not working. My problem is I am running kafka streaming job in yarn cluster mode and when I go and see logs after one hour in web UI,the logs are grown big. I like to know the steps where I can write logs in local file system/hdfs so I would go and see the logs in unix terminal instead of using web UI.

balakumar_b05 · ‎02-23-2017

Online	Offline
Last Visited	‎05-12-2017 06:27 AM

Date Registered	‎02-18-2017 10:55 AM
Last Visited	‎05-12-2017 06:27 AM
Total Messages Posted	10

How to perform lookup operation in spark dataframe

Spark Accumulators

RDD vs DATAFRAME

spark streaming

Re: Spark HBase Connector

Re: Spark HBase Connector

Spark HBase Connector

Re: spark hbase connector - Exception "java.lang.U...

Re: log4j.properties override spark executor

How to override default log4j properties in yarn c...