私は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')");
}
私はこのコマンドで私は "$ SNAPPY_HOME bin/run-example jarName.jar"を実行して、私のマスターに次にjarファイルを作成しました... –
あなたはあなたがチェックしている場所を詳しく教えてください。 $ SNAPPY_HOME bin/run-exampleはSparkをローカルモードで実行します。 –
ローカルマシンではyesですが、このコマンドを実行すると多くのログが出力されますが、このsql createコマンドでは処理されますが、クラスタ内のgeetingテーブルでは処理されません。 –