Merge pull request #21792 from taosdata/docs/TD-24885
docs: markdown format
This commit is contained in:
commit
c3fe54f6bf
|
@ -425,7 +425,7 @@ while(resultSet.next()){
|
||||||
|
|
||||||
This reqId can be used to request link tracing.
|
This reqId can be used to request link tracing.
|
||||||
|
|
||||||
```
|
```java
|
||||||
AbstractStatement aStmt = (AbstractStatement) connection.createStatement();
|
AbstractStatement aStmt = (AbstractStatement) connection.createStatement();
|
||||||
aStmt.execute("create database if not exists db", 1L);
|
aStmt.execute("create database if not exists db", 1L);
|
||||||
aStmt.executeUpdate("use db", 2L);
|
aStmt.executeUpdate("use db", 2L);
|
||||||
|
@ -955,7 +955,7 @@ public class SchemalessWsTest {
|
||||||
|
|
||||||
This reqId can be used to request link tracing.
|
This reqId can be used to request link tracing.
|
||||||
|
|
||||||
```
|
```java
|
||||||
writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS, 1L);
|
writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS, 1L);
|
||||||
```
|
```
|
||||||
|
|
||||||
|
@ -1016,7 +1016,7 @@ while(true) {
|
||||||
|
|
||||||
#### Assignment subscription Offset
|
#### Assignment subscription Offset
|
||||||
|
|
||||||
```
|
```java
|
||||||
long position(TopicPartition partition) throws SQLException;
|
long position(TopicPartition partition) throws SQLException;
|
||||||
Map<TopicPartition, Long> position(String topic) throws SQLException;
|
Map<TopicPartition, Long> position(String topic) throws SQLException;
|
||||||
Map<TopicPartition, Long> beginningOffsets(String topic) throws SQLException;
|
Map<TopicPartition, Long> beginningOffsets(String topic) throws SQLException;
|
||||||
|
@ -1027,7 +1027,7 @@ void seek(TopicPartition partition, long offset) throws SQLException;
|
||||||
|
|
||||||
Example usage is as follows.
|
Example usage is as follows.
|
||||||
|
|
||||||
```
|
```java
|
||||||
String topic = "offset_seek_test";
|
String topic = "offset_seek_test";
|
||||||
Map<TopicPartition, Long> offset = null;
|
Map<TopicPartition, Long> offset = null;
|
||||||
try (TaosConsumer<ResultBean> consumer = new TaosConsumer<>(properties)) {
|
try (TaosConsumer<ResultBean> consumer = new TaosConsumer<>(properties)) {
|
||||||
|
|
|
@ -428,7 +428,7 @@ while(resultSet.next()){
|
||||||
|
|
||||||
此 reqId 可用于请求链路追踪。
|
此 reqId 可用于请求链路追踪。
|
||||||
|
|
||||||
```
|
```java
|
||||||
AbstractStatement aStmt = (AbstractStatement) connection.createStatement();
|
AbstractStatement aStmt = (AbstractStatement) connection.createStatement();
|
||||||
aStmt.execute("create database if not exists db", 1L);
|
aStmt.execute("create database if not exists db", 1L);
|
||||||
aStmt.executeUpdate("use db", 2L);
|
aStmt.executeUpdate("use db", 2L);
|
||||||
|
@ -958,7 +958,7 @@ public class SchemalessWsTest {
|
||||||
|
|
||||||
此 reqId 可用于请求链路追踪。
|
此 reqId 可用于请求链路追踪。
|
||||||
|
|
||||||
```
|
```java
|
||||||
writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS, 1L);
|
writer.write(lineDemo, SchemalessProtocolType.LINE, SchemalessTimestampType.NANO_SECONDS, 1L);
|
||||||
```
|
```
|
||||||
|
|
||||||
|
@ -1019,7 +1019,7 @@ while(true) {
|
||||||
|
|
||||||
#### 指定订阅 Offset
|
#### 指定订阅 Offset
|
||||||
|
|
||||||
```
|
```java
|
||||||
long position(TopicPartition partition) throws SQLException;
|
long position(TopicPartition partition) throws SQLException;
|
||||||
Map<TopicPartition, Long> position(String topic) throws SQLException;
|
Map<TopicPartition, Long> position(String topic) throws SQLException;
|
||||||
Map<TopicPartition, Long> beginningOffsets(String topic) throws SQLException;
|
Map<TopicPartition, Long> beginningOffsets(String topic) throws SQLException;
|
||||||
|
@ -1030,7 +1030,7 @@ void seek(TopicPartition partition, long offset) throws SQLException;
|
||||||
|
|
||||||
示例代码:
|
示例代码:
|
||||||
|
|
||||||
```
|
```java
|
||||||
String topic = "offset_seek_test";
|
String topic = "offset_seek_test";
|
||||||
Map<TopicPartition, Long> offset = null;
|
Map<TopicPartition, Long> offset = null;
|
||||||
try (TaosConsumer<ResultBean> consumer = new TaosConsumer<>(properties)) {
|
try (TaosConsumer<ResultBean> consumer = new TaosConsumer<>(properties)) {
|
||||||
|
|
Loading…
Reference in New Issue