Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
Since you haven't updated Readme. We have spent so long time to found out how to read data within specific range. 
Added startingTime and endingTime options for configurations.
  • Loading branch information
violetkjs authored Mar 12, 2024
1 parent 55af037 commit 9ec16e3
Showing 1 changed file with 24 additions and 1 deletion.
25 changes: 24 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -346,7 +346,6 @@ You can use `org.apache.spark.sql.pulsar.JsonUtils.topicOffsets(Map[String, Mess
"earliest".
</td>
</tr>

<tr>
<td>`endingOffsets`</td>
<td>The following are valid values:<br>
Expand Down Expand Up @@ -376,6 +375,30 @@ You can use `org.apache.spark.sql.pulsar.JsonUtils.topicOffsets(Map[String, Mess
`MessageId.earliest ([8,-1,-1,-1,-1,-1,-1,-1,-1,-1,1,16,-1,-1,-1,-1,-1,-1,-1,-1,-1,1])` is not allowed.
</td>
</tr>
<tr>
<td>`startingTime`</td>
<td> A number in unit of milliseconds </td>
<td>No</td>
<td>None</td>
<td>batch queries</td>
<td>
For batch query, You can set a starting offset using milliseconds. <br>
The target time of this option is publishTime. <br>
Example: `1709254800000` (2024-03-01 01:00:00)
</td>
</tr>
<tr>
<td>`endingTime`</td>
<td> A number in unit of milliseconds </td>
<td>No</td>
<td>None</td>
<td>batch queries</td>
<td>
For batch query, You can set a ending offset using milliseconds. <br>
The target time of this option is publishTime. <br>
Example: `1709254800000` (2024-03-01 02:00:00)
</td>
</tr>

<tr>
<td>`failOnDataLoss`</td>
Expand Down

0 comments on commit 9ec16e3

Please sign in to comment.