Uses of Class
com.amazonaws.athena.connector.lambda.data.Block

Packages that use Block

Package	Description
com.amazonaws.athena.connector.lambda.data
com.amazonaws.athena.connector.lambda.data.writers
com.amazonaws.athena.connector.lambda.domain.predicate
com.amazonaws.athena.connector.lambda.domain.predicate.expression
com.amazonaws.athena.connector.lambda.handlers
com.amazonaws.athena.connector.lambda.metadata
com.amazonaws.athena.connector.lambda.records
com.amazonaws.athena.connector.lambda.security
com.amazonaws.athena.connector.lambda.serde
com.amazonaws.athena.connector.lambda.serde.v2
com.amazonaws.athena.connector.lambda.serde.v3
com.amazonaws.athena.connector.lambda.serde.v4
com.amazonaws.athena.connector.lambda.udf
com.amazonaws.athena.connector.validation
com.amazonaws.athena.connectors.tpcds

Uses of Block in com.amazonaws.athena.connector.lambda.data

Methods in com.amazonaws.athena.connector.lambda.data that return Block

Modifier and Type	Method	Description
Block	BlockAllocator.createBlock(org.apache.arrow.vector.types.pojo.Schema schema)	Creates an empty Apache Arrow Block with the provided Schema.
Block	BlockAllocatorImpl.createBlock(org.apache.arrow.vector.types.pojo.Schema schema)	Creates a block and registers it for later clean up if the block isn't explicitly closed by the caller.
Block	BlockSpiller.getBlock()	Provides access to the single buffered block in the event that spilled() is false.
Block	S3BlockSpiller.getBlock()	If spilled() returns false this can be used to access the block.
static Block	BlockUtils.newBlock(BlockAllocator allocator, String columnName, org.apache.arrow.vector.types.pojo.ArrowType type, Object... values)	Creates a new Block with a single column and populated with the provided values.
static Block	BlockUtils.newBlock(BlockAllocator allocator, String columnName, org.apache.arrow.vector.types.pojo.ArrowType type, Collection<Object> values)	Creates a new Block with a single column and populated with the provided values.
static Block	BlockUtils.newEmptyBlock(BlockAllocator allocator, String columnName, org.apache.arrow.vector.types.pojo.ArrowType type)	Creates a new, empty, Block with a single column.
protected Block	S3BlockSpiller.read(S3SpillLocation spillLocation, EncryptionKey key, org.apache.arrow.vector.types.pojo.Schema schema)	Reads a spilled block.
Block	S3BlockSpillReader.read(S3SpillLocation spillLocation, EncryptionKey key, org.apache.arrow.vector.types.pojo.Schema schema)	Reads a spilled block.

Methods in com.amazonaws.athena.connector.lambda.data with parameters of type Block

Modifier and Type	Method	Description
static int	BlockUtils.copyRows(Block srcBlock, Block dstBlock, int firstRow, int lastRow)	Copies a inclusive range of rows from one block to another.
static boolean	BlockUtils.isNullRow(Block block, int row)	Checks if a row is null by checking that all fields in that row are null (aka not set).
static String	BlockUtils.rowToString(Block block, int row)	Used to convert a specific row in the provided Block to a human readable string.
static void	BlockUtils.unsetRow(int row, Block block)	In some filtering situations it can be useful to 'unset' a row as an indication to a later processing stage that the row is irrelevant.
protected SpillLocation	S3BlockSpiller.write(Block block)	Writes (aka spills) a Block.
int	BlockWriter.RowWriter.writeRows(Block block, int rowNum)	Used to accumulate rows as part of a block.

Constructors in com.amazonaws.athena.connector.lambda.data with parameters of type Block

Constructor	Description
SimpleBlockWriter(Block block)	Basic constructor using a pre-allocated Block.

Uses of Block in com.amazonaws.athena.connector.lambda.data.writers

Methods in com.amazonaws.athena.connector.lambda.data.writers with parameters of type Block

Modifier and Type	Method	Description
boolean	GeneratedRowWriter.writeRow(Block block, int rowNum, Object context)

Uses of Block in com.amazonaws.athena.connector.lambda.domain.predicate

Methods in com.amazonaws.athena.connector.lambda.domain.predicate that return Block

Modifier and Type	Method	Description
Block	EquatableValueSet.getValueBlock()	Provides access to all the values in this ValueSet.
Block	Marker.getValueBlock()	Provides access to the Apache Arrow Block used to store the value of this marker.
Block	EquatableValueSet.getValues()	Provides access to all the values in this ValueSet.

Constructors in com.amazonaws.athena.connector.lambda.domain.predicate with parameters of type Block

Constructor	Description
EquatableValueSet(Block valueBlock, boolean whiteList, boolean nullAllowed)	Constructs a new EquatableValueSet.
Marker(Block block, int valuePosition, Marker.Bound bound, boolean nullValue)
Marker(Block valueBlock, Marker.Bound bound, boolean nullValue)	LOWER UNBOUNDED is specified with an empty value and a ABOVE bound UPPER UNBOUNDED is specified with an empty value and a BELOW bound
SharedBlockMarker(MarkerFactory factory, Block block, int valuePosition, Marker.Bound bound, boolean nullValue)

Uses of Block in com.amazonaws.athena.connector.lambda.domain.predicate.expression

Methods in com.amazonaws.athena.connector.lambda.domain.predicate.expression that return Block

Modifier and Type	Method	Description
Block	ConstantExpression.getValues()

Constructors in com.amazonaws.athena.connector.lambda.domain.predicate.expression with parameters of type Block

Constructor	Description
ConstantExpression(Block valueBlock, org.apache.arrow.vector.types.pojo.ArrowType type)

Uses of Block in com.amazonaws.athena.connector.lambda.handlers

Methods in com.amazonaws.athena.connector.lambda.handlers that return Block

Modifier and Type	Method	Description
protected Block	UserDefinedFunctionHandler.processRows(BlockAllocator allocator, Method udfMethod, Block inputRecords, org.apache.arrow.vector.types.pojo.Schema outputSchema)	Processes a group by rows.

Methods in com.amazonaws.athena.connector.lambda.handlers with parameters of type Block

Modifier and Type	Method	Description
protected Block	UserDefinedFunctionHandler.processRows(BlockAllocator allocator, Method udfMethod, Block inputRecords, org.apache.arrow.vector.types.pojo.Schema outputSchema)	Processes a group by rows.

Uses of Block in com.amazonaws.athena.connector.lambda.metadata

Methods in com.amazonaws.athena.connector.lambda.metadata that return Block

Modifier and Type	Method	Description
Block	GetSplitsRequest.getPartitions()	Returns the partitions that splits should be generated for.
Block	GetTableLayoutResponse.getPartitions()	Returns the partitions representing the table layout.

Constructors in com.amazonaws.athena.connector.lambda.metadata with parameters of type Block

Constructor	Description
GetSplitsRequest(FederatedIdentity identity, String queryId, String catalogName, TableName tableName, Block partitions, List<String> partitionCols, Constraints constraints, String continuationToken)	Constructs a new GetSplitsRequest object.
GetTableLayoutResponse(String catalogName, TableName tableName, Block partitions)	Constructs a new GetTableLayoutResponse object.

Uses of Block in com.amazonaws.athena.connector.lambda.records

Methods in com.amazonaws.athena.connector.lambda.records that return Block

Modifier and Type	Method	Description
Block	ReadRecordsResponse.getRecords()	Returns the records Block.

Constructors in com.amazonaws.athena.connector.lambda.records with parameters of type Block

Constructor	Description
ReadRecordsResponse(String catalogName, Block records)	Constructs a new ReadRecordsResponse object.

Uses of Block in com.amazonaws.athena.connector.lambda.security

Methods in com.amazonaws.athena.connector.lambda.security that return Block

Modifier and Type	Method	Description
Block	AesGcmBlockCrypto.decrypt(EncryptionKey key, byte[] bytes, org.apache.arrow.vector.types.pojo.Schema schema)
Block	BlockCrypto.decrypt(EncryptionKey key, byte[] bytes, org.apache.arrow.vector.types.pojo.Schema schema)	Used to decrypt and deserialize a Block from the provided bytes and schema.
Block	NoOpBlockCrypto.decrypt(EncryptionKey key, byte[] bytes, org.apache.arrow.vector.types.pojo.Schema schema)

Methods in com.amazonaws.athena.connector.lambda.security with parameters of type Block

Modifier and Type	Method	Description
byte[]	AesGcmBlockCrypto.encrypt(EncryptionKey key, Block block)
byte[]	BlockCrypto.encrypt(EncryptionKey key, Block block)	Used to encrypt the provided Block in its serialized form.
byte[]	NoOpBlockCrypto.encrypt(EncryptionKey key, Block block)

Uses of Block in com.amazonaws.athena.connector.lambda.serde

Methods in com.amazonaws.athena.connector.lambda.serde that return Block

Modifier and Type	Method	Description
Block	BlockDeserializer.deserialize(com.fasterxml.jackson.core.JsonParser jsonParser, com.fasterxml.jackson.databind.DeserializationContext deserializationContext)	Deprecated.

Methods in com.amazonaws.athena.connector.lambda.serde with parameters of type Block

Modifier and Type	Method	Description
void	BlockSerializer.serialize(Block block, com.fasterxml.jackson.core.JsonGenerator jsonGenerator, com.fasterxml.jackson.databind.SerializerProvider serializerProvider)	Deprecated.

Uses of Block in com.amazonaws.athena.connector.lambda.serde.v2

Methods in com.amazonaws.athena.connector.lambda.serde.v2 that return Block

Modifier and Type	Method	Description
Block	BlockSerDe.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 Block

Modifier and Type	Method	Description
void	BlockSerDe.Serializer.doSerialize(Block block, com.fasterxml.jackson.core.JsonGenerator jgen, com.fasterxml.jackson.databind.SerializerProvider provider)

Constructor parameters in com.amazonaws.athena.connector.lambda.serde.v2 with type arguments of type Block

Constructor	Description
Deserializer(VersionedSerDe.Deserializer<Block> blockDeserializer)
Deserializer(FederatedIdentitySerDe.Deserializer identityDeserializer, TableNameSerDe.Deserializer tableNameDeserializer, VersionedSerDe.Deserializer<Block> blockDeserializer, VersionedSerDe.Deserializer<Constraints> constraintsDeserializer)
Deserializer(TableNameSerDe.Deserializer tableNameDeserializer, VersionedSerDe.Deserializer<Block> blockDeserializer)
Deserializer(VersionedSerDe.Deserializer<Block> blockDeserializer)
Deserializer(VersionedSerDe.Deserializer<Block> blockDeserializer)
Deserializer(FederatedIdentitySerDe.Deserializer identityDeserializer, VersionedSerDe.Deserializer<Block> blockDeserializer, VersionedSerDe.Deserializer<org.apache.arrow.vector.types.pojo.Schema> schemaDeserializer)
Deserializer(VersionedSerDe.Deserializer<Block> blockDeserializer)
Serializer(VersionedSerDe.Serializer<Block> blockSerializer)
Serializer(FederatedIdentitySerDe.Serializer identitySerializer, TableNameSerDe.Serializer tableNameSerializer, VersionedSerDe.Serializer<Block> blockSerializer, VersionedSerDe.Serializer<Constraints> constraintsSerializer)
Serializer(TableNameSerDe.Serializer tableNameSerializer, VersionedSerDe.Serializer<Block> blockSerializer)
Serializer(VersionedSerDe.Serializer<Block> blockSerializer)
Serializer(VersionedSerDe.Serializer<Block> blockSerializer)
Serializer(FederatedIdentitySerDe.Serializer identitySerializer, VersionedSerDe.Serializer<Block> blockSerializer, VersionedSerDe.Serializer<org.apache.arrow.vector.types.pojo.Schema> schemaSerializer)
Serializer(VersionedSerDe.Serializer<Block> blockSerializer)

Uses of Block in com.amazonaws.athena.connector.lambda.serde.v3

Methods in com.amazonaws.athena.connector.lambda.serde.v3 that return Block

Modifier and Type	Method	Description
Block	BlockSerDeV3.Deserializer.doDeserialize(com.fasterxml.jackson.core.JsonParser jparser, com.fasterxml.jackson.databind.DeserializationContext ctxt)

Methods in com.amazonaws.athena.connector.lambda.serde.v3 with parameters of type Block

Modifier and Type	Method	Description
void	BlockSerDeV3.Serializer.doSerialize(Block block, com.fasterxml.jackson.core.JsonGenerator jgen, com.fasterxml.jackson.databind.SerializerProvider provider)

Uses of Block in com.amazonaws.athena.connector.lambda.serde.v4

Methods in com.amazonaws.athena.connector.lambda.serde.v4 that return Block

Modifier and Type	Method	Description
Block	BlockSerDeV4.Deserializer.doDeserialize(com.fasterxml.jackson.core.JsonParser jparser, com.fasterxml.jackson.databind.DeserializationContext ctxt)

Methods in com.amazonaws.athena.connector.lambda.serde.v4 with parameters of type Block

Modifier and Type	Method	Description
void	BlockSerDeV4.Serializer.doSerialize(Block block, com.fasterxml.jackson.core.JsonGenerator jgen, com.fasterxml.jackson.databind.SerializerProvider provider)

Constructor parameters in com.amazonaws.athena.connector.lambda.serde.v4 with type arguments of type Block

Constructor	Description
Deserializer(VersionedSerDe.Deserializer<Block> blockDeserializer, ArrowTypeSerDe.Deserializer arrowTypeDeserializer)
Serializer(VersionedSerDe.Serializer<Block> blockSerializer, ArrowTypeSerDe.Serializer arrowTypeSerializer)

Uses of Block in com.amazonaws.athena.connector.lambda.udf

Methods in com.amazonaws.athena.connector.lambda.udf that return Block

Modifier and Type	Method	Description
Block	UserDefinedFunctionRequest.getInputRecords()
Block	UserDefinedFunctionResponse.getRecords()

Constructors in com.amazonaws.athena.connector.lambda.udf with parameters of type Block

Constructor	Description
UserDefinedFunctionRequest(FederatedIdentity identity, Block inputRecords, org.apache.arrow.vector.types.pojo.Schema outputSchema, String methodName, UserDefinedFunctionType functionType)
UserDefinedFunctionResponse(Block records, String methodName)

Uses of Block in com.amazonaws.athena.connector.validation

Methods in com.amazonaws.athena.connector.validation with parameters of type Block

Modifier and Type	Method	Description
static GetSplitsResponse	LambdaMetadataProvider.getSplits(String catalog, TableName tableName, Constraints constraints, Block partitions, List<String> partitionCols, String contToken, String metadataFunction, FederatedIdentity identity)	This method builds and executes a GetSplitsRequest against the specified Lambda function.

Uses of Block in com.amazonaws.athena.connectors.tpcds

Methods in com.amazonaws.athena.connectors.tpcds with parameters of type Block

Modifier and Type	Method	Description
boolean	TPCDSRecordHandler.CellWriter.write(Block block, int rowNum, String value)	Converts a value from TPCDS' string representation into the appropriate Apache Arrow type and writes it to the correct field in the provided Block and row.