快照数据(表格未显示在集群中)

Question

我在Java中为snappy数据创建了一个程序。我无法在群集中获取表名。我也看不懂日志文件。 有什么提示吗？

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

Answer 1

我认为您没有从此行获得任何输出的原因是您没有在表中插入任何行 snappy.sql("select count(( from CUSTOMER"(.collect((。如果您将该行更改为 snappy.sql("select count(( from CUSTOMER"(.show((，它将显示表格的实际计数，在您的示例中为 0。