Ich habe ein Programm für Snappy-Daten in Java erstellt. Ich bin nicht in der Lage, den Tabellennamen im Cluster zu erhalten. Auch ich kann die Protokolldatei nicht verstehen. Irgendwelche Hinweise?SnappyData (Tabelle wird nicht im Cluster angezeigt)
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')");
}
Zuerst habe ich das Glas dann in meinem Master, durch diesen Befehl ich laufen "$ SNAPPY_HOME bin/run-Beispiel jarName.jar" ... –
Können Sie bitte erarbeiten, wo Sie überprüfen. $ SNAPPY_HOME bin/run-example führt Spark im lokalen Modus aus. –
Ja in einem lokalen Computer ich diesen Befehl ausführen, so viele Protokolle sind gekommen, in diesem einige Verarbeitung in diesem SQL-Befehl erstellen, aber nicht geeting Tabelle im Cluster –