Submitting Jobs to Your HDInsight Cluster - Pro Microsoft HDInsight: Hadoop on Windows - page 75

//For Blob Storage
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Blob;
namespace HadoopClient
{
class Program
{
static void Main(string[] args)
{
ListClusters();
CreateCluster();
DeleteCluster();
DoCustomMapReduce();
DoMapReduce();
DoHiveOperations();
MonitorCluster();
Console.Write("Press any key to exit");
Console.ReadKey();
}
//List existing HDI clusters
public static void ListClusters()
{
var store = new X509Store();
store.Open(OpenFlags.ReadOnly);
var cert = store.Certificates.Cast<X509Certificate2>().First(item
=> item.Thumbprint == Constants.thumbprint);
var creds = new HDInsightCertificateCredential(Constants.subscriptionId, cert);
var client = HDInsightClient.Connect(creds);
var clusters = client.ListClusters();
Console.WriteLine("The list of clusters and their details are");
foreach (var item in clusters)
{
Console.WriteLine("Cluster: {0}, Nodes: {1}, State: {2}, Version: {3}",
item.Name, item.ClusterSizeInNodes, item.State, item.Version);
}
}
//Create a new HDI cluster
public static void CreateCluster()
{
var store = new X509Store();
store.Open(OpenFlags.ReadOnly);
var cert = store.Certificates.Cast<X509Certificate2>().First(item
=> item.Thumbprint == Constants.thumbprint);
var creds = new HDInsightCertificateCredential(Constants.subscriptionId, cert);
var client = HDInsightClient.Connect(creds);