apache-spark - 从 spark 和 api 访问安全的 Ignite 集群

Question

我在 ignite 集群上启用了安全性。我在 ignite 文档之后从基本安全开始。

https://apacheignite.readme.io/docs/advanced-security

我在启用持久性的 xml 中添加了以下配置

<property name="authenticationEnabled" value="true"/>

它创建了一个超级用户，用户名和密码为 ignite。

我有一个从 Ignite Index 读取数据的 api

IgniteConfiguration cfg = new IgniteConfiguration();
cfg.setClientMode(true);
TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
TcpDiscoveryVmIpFinder vmIpFinder = new TcpDiscoveryVmIpFinder();
vmIpFinder.setAddresses(Arrays.asList("localhost"));
cfg.setDiscoverySpi(discoSpi);
cfg.setAuthenticationEnabled(true);
ignite = Ignition.start(cfg);

我在 IgniteConfiguration 类中找不到任何接受用户凭据的方法。如何验证我的客户端连接

另外我正在编写一个火花数据框来点燃。

df.write.format(FORMAT_IGNITE).option(OPTION_CONFIG_FILE,"default-config.xml")
    .option(OPTION_TABLE, "sampleTable")
    .option(OPTION_CREATE_TABLE_PRIMARY_KEY_FIELDS, "PK")
    .option(OPTION_STREAMER_ALLOW_OVERWRITE, "true")
    .mode(saveMode).save()

如何验证我的 spark 应用程序以写入 ignite。

我找不到任何在线资源。任何帮助表示赞赏。谢谢！

标签： apache-sparkignite