2017-04-07 6 views
0

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')"); 
} 
+0

Zuerst habe ich das Glas dann in meinem Master, durch diesen Befehl ich laufen "$ SNAPPY_HOME bin/run-Beispiel jarName.jar" ... –

+0

Können Sie bitte erarbeiten, wo Sie überprüfen. $ SNAPPY_HOME bin/run-example führt Spark im lokalen Modus aus. –

+0

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 –

Antwort

0

Ich denke, der Grund, warum Sie keine Ausgabe von dieser Linie erhalten ist, dass Sie keine Zeilen in der Tabelle snappy.sql („select count() von CUSTOMER“) eingefügt haben. Sammeln(). Und wenn Sie diese Zeile in snappy.sql ändern ("count() von CUSTOMER auswählen"). Show() zeigt Ihnen die tatsächliche Anzahl der Tabelle, die in Ihrem Beispiel 0 ist.

+0

aber Tabellenname auch nicht angezeigt .. wenn Tabelle erstellt wird ... so wird es auch dort angezeigt. –

Verwandte Themen