Skip to content

Commit

Permalink
style: DownsamplingExample
Browse files Browse the repository at this point in the history
  • Loading branch information
Sciator committed Nov 8, 2023
1 parent 3e021c7 commit b7ac548
Showing 1 changed file with 13 additions and 6 deletions.
19 changes: 13 additions & 6 deletions examples/src/main/java/com/influxdb/v3/DownsamplingExample.java
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,15 @@
import com.influxdb.v3.client.Point;
import com.influxdb.v3.client.PointValues;

/**
* The example depends on the "influxdb3-java" module and this module should be built first
* by running "mvn install" in the root directory.
*/
public final class DownsamplingExample {
public static void main(String[] args) throws Exception {
private DownsamplingExample() {
}

public static void main(final String[] args) throws Exception {
String host = "https://us-east-1-1.aws.cloud2.influxdata.com";
String token = "my-token";
String database = "my-database";
Expand All @@ -44,14 +51,14 @@ public static void main(String[] args) throws Exception {
.setTag("unit", "temperature")
.setField("avg", 24.5)
.setField("max", 45.0)
.setTimestamp(Instant.now().minusSeconds(-20*60));
.setTimestamp(Instant.now().minusSeconds(-20 * 60));
client.writePoint(point1);

Point point2 = Point.measurement("stat")
.setTag("unit", "temperature")
.setField("avg", 28.0)
.setField("max", 40.3)
.setTimestamp(Instant.now().minusSeconds(-10*60));
.setTimestamp(Instant.now().minusSeconds(-10 * 60));
client.writePoint(point2);

Point point3 = Point.measurement("stat")
Expand All @@ -72,8 +79,7 @@ public static void main(String[] args) throws Exception {
+ " WHERE\n"
+ " \"time\" >= now() - interval '1 hour'\n"
+ " GROUP BY window_start\n"
+ " ORDER BY window_start ASC;\n"
;
+ " ORDER BY window_start ASC;\n";


//
Expand All @@ -88,7 +94,8 @@ public static void main(String[] args) throws Exception {
return;
}

System.out.println(timestamp.toString()+": avg is "+row.getFloatField("avg")+", max is "+row.getFloatField("max"));
System.out.println(timestamp.toString() + ": avg is "
+ row.getFloatField("avg") + ", max is " + row.getFloatField("max"));

//
// write back downsampled date to 'stat_downsampled' measurement
Expand Down

0 comments on commit b7ac548

Please sign in to comment.