messageStream = env.addSource(new SimpleStringGenerator()); messageStream.addSink( new HBaseWriteSink(paraTool.get("tableName")

查看更多 →

选择方法二， 弹性云服务器 关机、重启后，修改后的主机名（new_hostname）仍然生效。但是，如果使用该弹性 云服务器 制作私有镜像，并使用生成的镜像重新创建弹性云 服务器 ，用户可以通过Cloud-init注入用户自定义名称（如new_new_hostname），并通过本节内容长久有效地修改静态主机名。

查看更多 →

sparkConf = new SparkConf().setAppName("KafkaWordCount"); JavaStreamingContext ssc = new JavaStreamingContext(sparkConf, new Duration(Long

查看更多 →

sparkConf = new SparkConf().setAppName("KafkaWordCount"); JavaStreamingContext ssc = new JavaStreamingContext(sparkConf, new Duration(Long

查看更多 →

sparkConf = new SparkConf().setAppName("KafkaWordCount"); JavaStreamingContext ssc = new JavaStreamingContext(sparkConf, new Duration(Long

查看更多 →

sparkConf = new SparkConf().setAppName("KafkaWordCount"); JavaStreamingContext ssc = new JavaStreamingContext(sparkConf, new Duration(Long

查看更多 →

重命名脱敏策略为mask_emp_new： 1 ALTER REDACTION POLICY mask_emp ON emp RENAME TO mask_emp_new; 新增脱敏列： 1 ALTER REDACTION POLICY mask_emp_new ON emp ADD COLUMN

查看更多 →

securityModeUrl = new StringBuilder("https://").append(restHostName).append(":21309").toString(); String nonSecurityModeUrl = new StringBuilder("http://")

查看更多 →

mv_name OWNER TO new_owner; 修改物化视图的列。 ALTER MATERIALIZED VIEW [ IF EXISTS ] mv_name RENAME [ COLUMN ] column_name TO new_column_name; 重命名物化视图。

查看更多 →

input = new ObsObjInfo().withBucket("mpc-east-2").withLocation("region01").withObject("input/hls/index.m3u8"); ObsObjInfo output = new ObsObjInfo()

查看更多 →

通过spark接口获取表中的数据 SparkConf conf = new SparkConf().setAppName("SparkHivetoHbase"); JavaSparkContext jsc = new JavaSparkContext(conf); HiveContext

查看更多 →

通过spark接口获取表中的数据 SparkConf conf = new SparkConf().setAppName("SparkHivetoHbase"); JavaSparkContext jsc = new JavaSparkContext(conf); HiveContext

查看更多 →

updateSubDevicesStatusEvent = new UpdateSubDevicesStatusEvent(); DeviceStatus deviceStatus = new DeviceStatus();

查看更多 →

sqlContext = new SQLContext(jsc); Configuration hbaseconf = new HBaseConfiguration().create(); JavaHBaseContext hBaseContext = new JavaHBaseContext(jsc

查看更多 →

ObsClient client = new ObsClient(accessKey, secretKey, config); // 设置多版本对象访问权限 try { SetObjectAclRequest request = new SetObjectAclRequest();

查看更多 →

ShowPublicKeyRequest showPublicKeyRequest = new ShowPublicKeyRequest() .withBody(new OperateKeyRequestBody().withKeyId(keyId));

查看更多 →

builder = new TopologyBuilder(); // 分隔符格式，当前采用“|”代替默认的“，”对tuple中的field进行分隔 // HdfsBolt必选参数 RecordFormat format = new DelimitedRecordFormat()

查看更多 →

DetectStandardByIdCardImageRequest request = new DetectStandardByIdCardImageRequest(); IvsStandardByIdCardImageRequestBody body = new IvsStandardByIdCardImageRequestBody();

查看更多 →

RENAME to new_table_name 语法格式 1 2 RENAME TABLE {[schema.]table_name TO new_table_name} [, ...]; 参数说明 schema 模式名称。 table_name 需要修改的表名称。 new_table_name

查看更多 →

RENAME to new_table_name 语法格式 1 2 RENAME TABLE {[schema.]table_name TO new_table_name} [, ...]; 参数说明 schema 模式名称。 table_name 需要修改的表名称。 new_table_name

查看更多 →

client = new MqttFactory().CreateManagedMqttClient(); client.ApplicationMessageReceivedHandler = new MqttAp

查看更多 →