1

SnappySQLJob を書き込もうとするとコンパイル エラーが発生します。依存関係がありませんか?

エラーメッセージは次のとおりです。

タイプ org.apache.spark.sql.catalyst.TableIdentifier を解決できません。必要な .class ファイルから間接的に参照されている

@Override
    public Object runJob(Object sparkContext, Config jobConfig) {
        SnappyContext snappyContext = (SnappyContext)sparkContext;

        String fileResource = "data.csv";

        DataFrame dataFrame = snappyContext.read()
                .format("com.databricks.spark.csv")
                .option("header", "true")
                .option("inferSchema", "true")
                .load(fileResource);

        // Compile-Time error is on this line
        dataFrame.write().insertInto("example_table_col");


        return null;
    }

ここに私の pom.xml 依存関係があります:

    <dependency>
        <groupId>io.snappydata</groupId>
        <artifactId>snappy-core_2.10</artifactId>
        <version>0.2.1-PREVIEW</version>
    </dependency>
    <dependency>
        <groupId>io.snappydata</groupId>
        <artifactId>snappy-tools_2.10</artifactId>
        <version>0.2.1-PREVIEW</version>
        <exclusions>
            <exclusion>
                <artifactId>jdk.tools</artifactId>
                <groupId>jdk.tools</groupId>
            </exclusion>
            <exclusion>
                <artifactId>logback-classic</artifactId>
                <groupId>ch.qos.logback</groupId>
            </exclusion>
        </exclusions>
    </dependency>
4

1 に答える 1

1

この古いリリースにはspark-catalyst依存関係がないようです。代わりに 0.5 リリース バージョンにアップグレードすることをお勧めします (snappy-tools現在は と呼ばれsnappy-clusterています)。snappydata クラスターも 0.5 にアップグレードする必要があります。

0.2.1 リリースでは、以下で問題を修正する必要があります。

<dependency>
  <groupId>io.snappydata</groupId>
  <artifactId>snappy-spark-catalyst_2.10</artifactId>
  <version>1.6.0-BETA</version>
</dependency>
<dependency>
  <groupId>io.snappydata</groupId>
  <artifactId>snappy-spark-sql_2.10</artifactId>
  <version>1.6.0-BETA</version>
</dependency>
于 2016-08-06T14:00:58.247 に答える