【发布时间】: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