Package com.amazonaws.athena.connectors.influxdb

Class InfluxDBQueryBuilder

java.lang.Object

com.amazonaws.athena.connectors.influxdb.InfluxDBQueryBuilder

public class InfluxDBQueryBuilder
extends Object

Builds SQL queries for InfluxDB 3 from Athena SDK constraints. Since InfluxDB speaks SQL natively, we construct standard SQL strings directly.

Method Summary

Modifier and Type	Method	Description
static String	buildSql(org.apache.arrow.vector.types.pojo.Schema schema, String tableName, Constraints constraints)	Builds a complete SQL query from the schema, table name, and constraints.
static String	buildSql(org.apache.arrow.vector.types.pojo.Schema schema, String tableName, Constraints constraints, String timeLowerMillis, String timeUpperMillis)	Builds a complete SQL query, additionally narrowing the query to a single time-based split via a half-open [lower, upper) predicate on the time column.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

buildSql

public static String buildSql(org.apache.arrow.vector.types.pojo.Schema schema,
                              String tableName,
                              Constraints constraints)

Builds a complete SQL query from the schema, table name, and constraints.

buildSql

public static String buildSql(org.apache.arrow.vector.types.pojo.Schema schema,
                              String tableName,
                              Constraints constraints,
                              String timeLowerMillis,
                              String timeUpperMillis)

Builds a complete SQL query, additionally narrowing the query to a single time-based split via a half-open [lower, upper) predicate on the time column. The bounds are epoch-millisecond strings taken from the split properties; when either is null no time-based narrowing is applied.