Uses of Class
com.amazonaws.athena.connector.lambda.domain.Split
-
-
Uses of Split in com.amazonaws.athena.connector.lambda.domain
Methods in com.amazonaws.athena.connector.lambda.domain that return Split Modifier and Type Method Description Split
Split.Builder. build()
Builds the Split -
Uses of Split in com.amazonaws.athena.connector.lambda.metadata
Methods in com.amazonaws.athena.connector.lambda.metadata that return types with arguments of type Split Modifier and Type Method Description Set<Split>
GetSplitsResponse. getSplits()
Returns the generated splits.Constructors in com.amazonaws.athena.connector.lambda.metadata with parameters of type Split Constructor Description GetSplitsResponse(String catalogName, Split split)
Constructs a new GetSplitsResponse object.Constructor parameters in com.amazonaws.athena.connector.lambda.metadata with type arguments of type Split Constructor Description GetSplitsResponse(String catalogName, Set<Split> splits)
Constructs a new GetSplitsResponse object.GetSplitsResponse(String catalogName, Set<Split> splits, String continuationToken)
Constructs a new GetSplitsResponse object. -
Uses of Split in com.amazonaws.athena.connector.lambda.records
Methods in com.amazonaws.athena.connector.lambda.records that return Split Modifier and Type Method Description Split
ReadRecordsRequest. getSplit()
Returns he split being read.Constructors in com.amazonaws.athena.connector.lambda.records with parameters of type Split Constructor Description ReadRecordsRequest(FederatedIdentity identity, String catalogName, String queryId, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Split split, Constraints constraints, long maxBlockSize, long maxInlineBlockSize)
Constructs a new ReadRecordsRequest object. -
Uses of Split in com.amazonaws.athena.connector.lambda.serde.v2
Methods in com.amazonaws.athena.connector.lambda.serde.v2 that return Split Modifier and Type Method Description Split
SplitSerDe.Deserializer. doDeserialize(com.fasterxml.jackson.core.JsonParser jparser, com.fasterxml.jackson.databind.DeserializationContext ctxt)
Methods in com.amazonaws.athena.connector.lambda.serde.v2 with parameters of type Split Modifier and Type Method Description void
SplitSerDe.Serializer. doSerialize(Split split, com.fasterxml.jackson.core.JsonGenerator jgen, com.fasterxml.jackson.databind.SerializerProvider provider)
-
Uses of Split in com.amazonaws.athena.connector.validation
Methods in com.amazonaws.athena.connector.validation with parameters of type Split Modifier and Type Method Description static ReadRecordsResponse
LambdaRecordProvider. readRecords(String catalog, TableName tableName, Constraints constraints, org.apache.arrow.vector.types.pojo.Schema schema, Split split, String recordFunction, FederatedIdentity identity)
This method builds and executes a ReadRecordsRequest against the specified Lambda function. -
Uses of Split in com.amazonaws.athena.connectors.clickhouse
Methods in com.amazonaws.athena.connectors.clickhouse with parameters of type Split Modifier and Type Method Description PreparedStatement
ClickHouseRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
-
Uses of Split in com.amazonaws.athena.connectors.cloudera
Methods in com.amazonaws.athena.connectors.cloudera with parameters of type Split Modifier and Type Method Description PreparedStatement
HiveRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
PreparedStatement
ImpalaRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
protected String
HiveQueryStringBuilder. getFromClauseWithSplit(String catalogName, String schema, String table, Split split)
protected String
ImpalaQueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
HiveQueryStringBuilder. getPartitionWhereClauses(Split split)
protected List<String>
ImpalaQueryStringBuilder. getPartitionWhereClauses(Split split)
-
Uses of Split in com.amazonaws.athena.connectors.datalakegen2
Methods in com.amazonaws.athena.connectors.datalakegen2 with parameters of type Split Modifier and Type Method Description protected String
DataLakeGen2QueryStringBuilder. appendLimitOffset(Split split, Constraints constraints)
PreparedStatement
DataLakeGen2RecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
protected String
DataLakeGen2QueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
DataLakeGen2QueryStringBuilder. getPartitionWhereClauses(Split split)
As Gen2 does not support partitioning returning empty list -
Uses of Split in com.amazonaws.athena.connectors.db2
Methods in com.amazonaws.athena.connectors.db2 with parameters of type Split Modifier and Type Method Description PreparedStatement
Db2RecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
Builds split SQL string and returns prepared statement.protected String
Db2QueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
Formatting SQL query statement.protected List<String>
Db2QueryStringBuilder. getPartitionWhereClauses(Split split)
Creates partition framing clause by taking information from split property. -
Uses of Split in com.amazonaws.athena.connectors.db2as400
Methods in com.amazonaws.athena.connectors.db2as400 with parameters of type Split Modifier and Type Method Description PreparedStatement
Db2As400RecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
Builds split SQL string and returns prepared statement.protected String
Db2As400QueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
Formatting SQL query statement.protected List<String>
Db2As400QueryStringBuilder. getPartitionWhereClauses(Split split)
Creates partition framing clause by taking information from split property. -
Uses of Split in com.amazonaws.athena.connectors.hortonworks
Methods in com.amazonaws.athena.connectors.hortonworks with parameters of type Split Modifier and Type Method Description PreparedStatement
HiveRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
protected String
HiveQueryStringBuilder. getFromClauseWithSplit(String catalogName, String schema, String table, Split split)
protected List<String>
HiveQueryStringBuilder. getPartitionWhereClauses(Split split)
-
Uses of Split in com.amazonaws.athena.connectors.jdbc
Methods in com.amazonaws.athena.connectors.jdbc with parameters of type Split Modifier and Type Method Description PreparedStatement
MultiplexingJdbcRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
-
Uses of Split in com.amazonaws.athena.connectors.jdbc.manager
Methods in com.amazonaws.athena.connectors.jdbc.manager with parameters of type Split Modifier and Type Method Description protected String
JdbcSplitQueryBuilder. appendLimitOffset(Split split)
protected String
JdbcSplitQueryBuilder. appendLimitOffset(Split split, Constraints constraints)
abstract PreparedStatement
JdbcRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
Builds split SQL string and returns prepared statement.PreparedStatement
JdbcSplitQueryBuilder. buildSql(Connection jdbcConnection, String catalog, String schema, String table, org.apache.arrow.vector.types.pojo.Schema tableSchema, Constraints constraints, Split split)
Common logic to build Split SQL including constraints translated in where clause.protected abstract String
JdbcSplitQueryBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected abstract List<String>
JdbcSplitQueryBuilder. getPartitionWhereClauses(Split split)
protected PreparedStatement
JdbcSplitQueryBuilder. prepareStatementWithSql(Connection jdbcConnection, String catalog, String schema, String table, org.apache.arrow.vector.types.pojo.Schema tableSchema, Constraints constraints, Split split, String columnNames)
-
Uses of Split in com.amazonaws.athena.connectors.mysql
Methods in com.amazonaws.athena.connectors.mysql with parameters of type Split Modifier and Type Method Description PreparedStatement
MySqlRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
protected String
MySqlQueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
MySqlQueryStringBuilder. getPartitionWhereClauses(Split split)
-
Uses of Split in com.amazonaws.athena.connectors.oracle
Methods in com.amazonaws.athena.connectors.oracle with parameters of type Split Modifier and Type Method Description protected String
OracleQueryStringBuilder. appendLimitOffset(Split split, Constraints constraints)
PreparedStatement
OracleRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
protected String
OracleQueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
OracleQueryStringBuilder. getPartitionWhereClauses(Split split)
-
Uses of Split in com.amazonaws.athena.connectors.postgresql
Methods in com.amazonaws.athena.connectors.postgresql with parameters of type Split Modifier and Type Method Description PreparedStatement
PostGreSqlRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
PreparedStatement
PostGreSqlQueryStringBuilder. buildSql(Connection jdbcConnection, String catalog, String schema, String table, org.apache.arrow.vector.types.pojo.Schema tableSchema, Constraints constraints, Split split)
protected String
PostGreSqlQueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
PostGreSqlQueryStringBuilder. getPartitionWhereClauses(Split split)
-
Uses of Split in com.amazonaws.athena.connectors.saphana
Methods in com.amazonaws.athena.connectors.saphana with parameters of type Split Modifier and Type Method Description PreparedStatement
SaphanaRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
PreparedStatement
SaphanaQueryStringBuilder. buildSql(Connection jdbcConnection, String catalog, String schema, String table, org.apache.arrow.vector.types.pojo.Schema tableSchema, Constraints constraints, Split split)
protected String
SaphanaQueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
SaphanaQueryStringBuilder. getPartitionWhereClauses(Split split)
-
Uses of Split in com.amazonaws.athena.connectors.snowflake
Methods in com.amazonaws.athena.connectors.snowflake with parameters of type Split Modifier and Type Method Description protected String
SnowflakeQueryStringBuilder. appendLimitOffset(Split split)
logic to apply limits in query, if partition value does not contain "-", no limit and offset condition to be applied, else apply limits and offset as per "p-limit-3000-offset-0" pattern.PreparedStatement
SnowflakeRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
protected String
SnowflakeQueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
SnowflakeQueryStringBuilder. getPartitionWhereClauses(Split split)
-
Uses of Split in com.amazonaws.athena.connectors.sqlserver
Methods in com.amazonaws.athena.connectors.sqlserver with parameters of type Split Modifier and Type Method Description protected String
SqlServerQueryStringBuilder. appendLimitOffset(Split split, Constraints constraints)
PreparedStatement
SqlServerRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
protected String
SqlServerQueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
SqlServerQueryStringBuilder. getPartitionWhereClauses(Split split)
In case of partitioned table, custom query will be formed to get specific partition otherwise empty list will be returned -
Uses of Split in com.amazonaws.athena.connectors.synapse
Methods in com.amazonaws.athena.connectors.synapse with parameters of type Split Modifier and Type Method Description protected String
SynapseQueryStringBuilder. appendLimitOffset(Split split, Constraints constraints)
PreparedStatement
SynapseRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
protected String
SynapseQueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
SynapseQueryStringBuilder. getPartitionWhereClauses(Split split)
In case of partitioned table, custom query will be formed to get specific partition otherwise empty list will be returned -
Uses of Split in com.amazonaws.athena.connectors.teradata
Methods in com.amazonaws.athena.connectors.teradata with parameters of type Split Modifier and Type Method Description protected String
TeradataQueryStringBuilder. appendLimitOffset(Split split, Constraints constraints)
PreparedStatement
TeradataRecordHandler. buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)
protected String
TeradataQueryStringBuilder. getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>
TeradataQueryStringBuilder. getPartitionWhereClauses(Split split)
-