【问题标题】:SnappyData(Table is not showing in cluster)SnappyData(表未显示在集群中)
【发布时间】:2017-04-14 12:06:47
【问题描述】:

我已经为 Java 中的快速数据创建了一个程序。 我无法在集群中获取表名。我也无法理解日志文件。有什么提示吗?

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

【问题讨论】:

  • 首先我创建了 jar 然后在我的 master 中,通过这个命令我运行 "$SNAPPY_HOME bin/run-example jarName.jar"...
  • 您能否详细说明您检查的位置。 $SNAPPY_HOME bin/run-example 将以本地模式运行 Spark。
  • 是的,我在本地机器上运行该命令,出现了这么多日志,在该 sql create 命令中进行了一些处理,但在集群中没有 geeting 表
  • 你在哪里检查表名?这是本地 [*] 模式,因此只有该程序可以看到表(或在端口 4040 上的 Spark GUI 中)。如果你有这样的查询:snappy.sql("select count(*) from CUSTOMER").collect(),在上面的代码中 sn-p 是否有效?
  • 我正在检查我的 snappy 集群,snappy.sql("select count(*) from CUSTOMER").collect() 这行不起作用

标签: java eclipse snappy snappydata


【解决方案1】:

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

【讨论】:

  • 但表名也没有显示..如果表已创建...所以它也会显示在那里。
猜你喜欢
  • 2017-08-27
  • 2022-11-03
  • 1970-01-01
  • 2021-12-29
  • 1970-01-01
  • 1970-01-01
  • 2018-12-22
  • 1970-01-01
  • 2016-04-05
相关资源
最近更新 更多