-
使用kubernetes官方Java SDK访问CCI
![]()
} } builder.setVerifyingSsl(config.verifySSL()); builder.setBasePath(server); builder.setAuthentication(new
来自：帮助中心 -
向量检索的客户端代码示例（Java）
![]()
NoopHostnameVerifier.INSTANCE); RestClientBuilder builder = RestClient.builder(httpHosts).setHttpClientConfigCallback(httpClientBuilder
来自：帮助中心 -
使用KafkaStreams统计数据
![]()
createWordCountStream(final StreamsBuilder builder) { // 从 input-topic 接收输入记录 final KStream<String, String> source = builder.stream(INPUT_TOPIC_NAME);
来自：帮助中心 -
java样例代码
-
提高RabbitMQ性能
![]()
ch.confirmSelect(); AMQP.BasicProperties.Builder bldr = new AMQP.BasicProperties.Builder(); for (int i = 0; i < 100000; i++) {
来自：帮助中心 -
HDFS C API接口介绍
![]()
hdfsStreamBuilderSetBufferSize(builder,100); hdfsStreamBuilderSetReplication(builder,20); hdfsStreamBuilderSetDefaultBlockSize(builder,10485760); readFile
来自：帮助中心 -
HDFS C API接口介绍
![]()
hdfsStreamBuilderSetBufferSize(builder,100); hdfsStreamBuilderSetReplication(builder,20); hdfsStreamBuilderSetDefaultBlockSize(builder,10485760); readFile
来自：帮助中心 -
Spark Core样例程序（Scala）
![]()
FemaleInfoCollection： 样例：类CollectMapper val spark = SparkSession .builder() .appName("CollectFemaleInfo") .config("spark.some.config.option"
来自：帮助中心 -
统计查询
![]()
LemonTable(table); // Build LemonQuery. LemonQuery query = LemonQuery.builder() // Set ad-hoc query condition. .setQuery("education:bachelor
来自：帮助中心 -
Spark从Hive读取数据再写入HBase样例程序（Python）
![]()
import SparkSession # 创建SparkSession spark = SparkSession\ .builder\ .appName("SparkHivetoHbase") \ .getOrCreate() # 向sc
来自：帮助中心 -
使用Lettuce连接Cluster集群实例时，规格变更的异常处理
![]()
ClusterTopologyRefreshOptions topologyRefreshOptions = ClusterTopologyRefreshOptions.builder() // 每隔time毫秒周期性刷新 .enablePeriodicRefresh(Duration
来自：帮助中心 -
使用KafkaStreams统计数据
![]()
createWordCountStream(final StreamsBuilder builder) { // 从 input-topic 接收输入记录 final KStream<String, String> source = builder.stream(INPUT_TOPIC_NAME);
来自：帮助中心 -
Spark Core样例程序（Scala）
![]()
bigdata.spark.examples.FemaleInfoCollection： val spark = SparkSession .builder() .appName("CollectFemaleInfo") .config("spark.some.config.option"
来自：帮助中心 -
通过Rest Low Level Client接入Elasticsearch集群
![]()
xxx.xxx", "xxx.xxx.xxx.xxx"); RestClientBuilder builder = RestClient.builder(constructHttpHosts(host, 9200, "http")); /**
来自：帮助中心 -
Spark从Hive读取数据再写入HBase样例程序（Python）
![]()
import SparkSession # 创建SparkSession spark = SparkSession\ .builder\ .appName("SparkHivetoHbase") \ .getOrCreate() # 向sc
来自：帮助中心 -
Spark从Hive读取数据再写入HBase样例程序（Python）
![]()
import SparkSession # 创建SparkSession spark = SparkSession\ .builder\ .appName("SparkHivetoHbase") \ .getOrCreate() # 向sc
来自：帮助中心 -
本地应用注入iDME注解示例
![]()
@Bean public RestTemplate restTemplate(RestTemplateBuilder builder) throws NoSuchAlgorithmException, KeyManagementException {
来自：帮助中心 -
pyspark样例代码
![]()
pyspark.sql import SparkSession 创建session 1 sparkSession = SparkSession.builder.appName("datasource-mongo").getOrCreate() 设置连接参数 1 2 3 4 5 6 url =
来自：帮助中心 -
Spark jar 如何读取上传文件
![]()
def main(args:Array[String]): Unit = { val spark = SparkSession.builder .appName("SparkTest") .getOrCreate() // driver 获取上传文件
来自：帮助中心 -
Spark SQL样例程序（Python）
![]()
exit(-1) # 初始化SparkSession和SQLContext sc = SparkSession.builder.appName("CollectFemaleInfo").getOrCreate() sqlCtx = SQLContext(sc)
来自：帮助中心 -
Spark同步HBase数据到CarbonData（Java）
![]()
static void main(String[] args) throws Exception { spark = SparkSession.builder().appName("HBaseExternalHiveToCarbon").getOrCreate(); Timer timer
来自：帮助中心
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
