Member since
09-25-2015
230
Posts
276
Kudos Received
39
Solutions
11-11-2015
02:39 PM
1 Kudo
@azeltov@hortonworks.com See what I tried. First, with spark-shell 1- Download jar and register to local maven su - zeppelin
wget https://raw.githubusercontent.com/gbraccialli/HiveUtils/master/target/HiveUtils-1.0-SNAPSHOT-jar-with-dependencies.jar /tmp/HiveUtils-1.0-SNAPSHOT-jar-with-dependencies.jar
mvn org.apache.maven.plugins:maven-install-plugin:2.5.2:install-file \
-Dfile=/tmp/HiveUtils-1.0-SNAPSHOT-jar-with-dependencies.jar \
-DgroupId=com.github.gbraccialli \
-DartifactId=HiveUtils \
-Dversion=1.0-SNAPSHOT \
-Dpackaging=jar
... View more
11-11-2015
02:23 PM
@Neeraj I needed to add credential to hive-site to wasb to work inside hive. Did it work for you only with hdfs-site?
... View more
11-11-2015
02:59 AM
see this jira: https://issues.apache.org/jira/browse/ZEPPELIN-150
... View more
11-11-2015
02:57 AM
@azeltov@hortonworks.com I tried now and getting ClassNotFoundException with z.load("/path/to/jar") and also with maven local repo dependency. Could you make it work with zeppelin?
... View more
11-10-2015
09:41 PM
1 Kudo
@azeltov@hortonworks.com see below github project for hive udf, exactly same jar built for hive project works fine with spark. The scala code is above: https://github.com/gbraccialli/HiveUtils
... View more
11-09-2015
02:10 PM
1 Kudo
Worth mentioning our Zeppelin Gallery: https://github.com/hortonworks-gallery/zeppelin-notebooks
... View more
11-06-2015
03:55 PM
Same happened to me. I was shoing ambari views after a cluster installation to a prospect and prospect clicked on the Data Visualization tab. I said: WOW!!!! I haven't seen this before!!! Good stuff!
... View more
11-02-2015
11:11 PM
@Neeraj what would be the steps to use WASB in a cluster deployed using cloudbreak? Would that work if I just add key to hdfs-site?
... View more
10-26-2015
11:09 PM
4 Kudos
Sharing source code I wrote to a prospect that wants to try Phoenix + .NET. It's a simple code that POST the query to Phoenix Server and parse result JSON and prints results on console: using System;
using System.Net;
using System.Collections.Generic;
using Newtonsoft.Json;
using System.Text;
namespace ConsoleApplication1
{
class PhoenixSample
{
public class FirstFrame
{
public String offset;
public List<List<String>> rows;
}
public class Result
{
public FirstFrame firstFrame;
public int updateCount;
}
public class PhoenixResult
{
public string response { get; set; }
public List<Result> results { get; set; }
}
static void Main(string[] args)
{
try
{
string url = "http://192.168.56.203:8765";
string query = "select * from test";
var syncClient = new WebClient();
syncClient.Headers["request"] = "{\"request\":\"prepareAndExecute\",\"connectionId\":\"b27cbc83-a514-49f0-9bbe-f15d8bfb3532\",\"sql\":\"" + query + "\",\"maxRowCount\":-1}";
syncClient.Headers["Content-Type"] = "application/json";
byte[] responseArray = syncClient.UploadData(url, "POST", Encoding.ASCII.GetBytes(""));
string json = Encoding.ASCII.GetString(responseArray);
System.Diagnostics.Debug.WriteLine("teste");
System.Diagnostics.Debug.WriteLine("json=" + json);
PhoenixResult test = JsonConvert.DeserializeObject<PhoenixResult>(json);
System.Diagnostics.Debug.WriteLine(test.response);
System.Diagnostics.Debug.WriteLine(test.results[0].updateCount);
for (int i = 0; i < test.results[0].firstFrame.rows.Count; i++)
{
for (int j = 0; j < test.results[0].firstFrame.rows[i].Count; j++)
{
System.Diagnostics.Debug.Write("row # " + i + " col # " + j + " = ");
System.Diagnostics.Debug.WriteLine(test.results[0].firstFrame.rows[i][j]);
}
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
Console.Read();
}
}
}
}
... View more
Labels:
10-22-2015
05:21 PM
@abajwa@hortonworks.com I tried collect-stream-logs but I got error below when trying to use the imported template. Do you know what version of nifi it's supposed to work with?
... View more
- « Previous
- Next »