1. Window function: 1. Create table: — Create kafka table CREATE TABLE bid ( bidtime TIMESTAMP(3), price DECIMAL(10, 2) , item STRING, WATERMARK FOR bidtime AS bidtime ) WITH ( ‘connector’ = ‘kafka’, ‘topic’ = ‘bid’, — the topic of the data ‘properties.bootstrap.servers’ = ‘master:9092,node1:9092,node2:9092’, — broker list ‘properties.group.id’ = ‘testGroup’, — consumer group ‘scan.startup.mode’ […]
Tag: sage
Solution to the “red” message when running tensorfow
Problem display When running tensor, a large amount of “red” information often appears, as shown below: import tensorflow as tf x = tf.constant(1) print(x) code display 2023-11-12 17:39:04.668566: I tensorflow/core/common_runtime/gpu/gpu_device.cc:1561] Found device 0 with properties: pciBusID: 0000:01:00.0 name: GeForce MX250 computeCapability: 6.1 coreClock: 1.582GHz coreCount: 3 deviceMemorySize: 2.00GiB deviceMemoryBandwidth: 52.21GiB/s 2023-11-12 17:39:04.668943: I tensorflow/stream_executor/platform/default/dso_loader.cc:44] Successfully […]
The Tao of Git Commit: Standardized Commit Message Writing Guide
1 commit message specification The commit message format includes three parts: Header, Body and Footer <type>(<scope>): <subject> <body> <footer> Header is required, Body and Footer can be omitted. 1.1 Header Type (required) type is used to describe the category of git commit, and the following identifiers are allowed. feat：New function (Feature) “Feat” is used to […]
Basic usage of lambda expressions
Introduction Lambda expressions are an important feature introduced in Java 8 that allow us to write anonymous functions in a more concise way. Before discussing Lambda expressions, let us first review the problems with anonymous inner classes. Problems with anonymous inner classes Before Java 8, we usually used anonymous inner classes to pass behavior. For […]
Mybatis usage steps
WiFi usage of esp32 idf
ESP32’s WiFi has three modes, AP mode, STA mode and smart_config. In order to facilitate management, I integrated the initialization of these three modes into one file for later use. Project directory moqi@5d30a855738f:~/project/esp32-demo/project$ tree ├── CMakeLists.txt ├── components │ └── hardware │ ├── CMakeLists.txt │ ├── component.mk │ ├── inc │ │ └── Wifi_Hardware.h │ […]
.NET quickly connects with Jiguang message push
What is push message? Many mobile APPs will push messages to users from time to time. For example, some news APPs will push news that the user may be interested in, or if the APP is updated, they will push messages to the user whether to choose to update, etc. This is the so-called ” […]
Android Studio development controls and page usage
1. Control 1.1 button Get button: Button btn_scan_view=(Button) findViewById(R.id.button_get); Button click event: //Click the start generation button to listen for events btn_get.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { //Click event content } }); 1.2 Input box Input box: EditText edittext=findViewById(R.id.editTextText);//Input box Get the input content: String input= edittext.getText().toString(); 1.3 Images Get the image […]
Quick development and usage guide for service governance plug-ins under the Sermant framework
Summary Sermant is a cloud-native agentless service mesh based on Java bytecode enhancement technology. It is non-intrusive, plug-inable and high-performance. Through the Sermant core framework, plug-ins for various service management purposes can be easily developed, including load balancing, flow control, label routing, label transparent transmission, etc. In this article, we use a case to explain […]
Flink SQL — command line usage
1. Start Flink SQL First start the Flink cluster and select independent cluster mode or session mode. The session mode is selected here: yarn-session.sh -d Starting the Flink SQL client: sql-client.sh 2. kafka SQL connector When using kafka as a data source, you need to upload the jar package to flnik’s lib: /usr/local/soft/flink-1.15.2/lib You can […]