2017-04-07 6 views
0

私はJavaのスナッピーデータ用に1つのプログラムを作成しました。 クラスタ内でテーブル名を取得できません。また、私はログファイルを理解できません。何かヒント?SnappyData(テーブルがクラスタで表示されていません)

public static void main(String[] args) 
{ 
    SparkSession spark = SparkSession 
     .builder() 
     .appName("SparkApp") 
     .master("local[*]") 
     .getOrCreate(); 
    JavaSparkContext jsc = new JavaSparkContext(spark.sparkContext()); 
    SnappySession snappy = new SnappySession(spark.sparkContext()); 
    snappy.dropTable("CUSTOMER",true); 
    snappy.sql("CREATE TABLE CUSTOMER (" + 
      "C_CUSTKEY  INTEGER NOT NULL," + 
      "C_NAME  VARCHAR(25) NOT NULL," + 
      "C_ADDRESS  VARCHAR(40) NOT NULL," + 
      "C_NATIONKEY INTEGER NOT NULL," + 
      "C_PHONE  VARCHAR(15) NOT NULL," + 
      "C_ACCTBAL  DECIMAL(15,2) NOT NULL," + 
      "C_MKTSEGMENT VARCHAR(10) NOT NULL," + 
      "C_COMMENT  VARCHAR(117) NOT NULL)" + 
      "USING COLUMN OPTIONS (PARTITION_BY 'C_CUSTKEY')"); 
} 
+0

私はこのコマンドで私は "$ SNAPPY_HOME bin/run-example jarName.jar"を実行して、私のマスターに次にjarファイルを作成しました... –

+0

あなたはあなたがチェックしている場所を詳しく教えてください。 $ SNAPPY_HOME bin/run-exampleはSparkをローカルモードで実行します。 –

+0

ローカルマシンではyesですが、このコマンドを実行すると多くのログが出力されますが、このsql createコマンドでは処理されますが、クラスタ内のgeetingテーブルでは処理されません。 –

答えて

0

私はあなたがこのラインから任意の出力を取得されていません理由は、あなたがテーブルsnappy.sql(「SELECT COUNT()顧客からの」)内の任意の行を挿入していないことだと思います。収集します()。そして、その行をsnappy.sql( "select count()from CUSTOMER")に変更すると、show()は実際のテーブルの数を表示します。

+0

でもテーブル名が表示されません。テーブルが作成されていれば...そこにも表示されます。 –

関連する問題