static List<Object> |
DDBTypeUtils.coerceListToExpectedType(Object value,
org.apache.arrow.vector.types.pojo.Field field,
DDBRecordMetadata recordMetadata) |
Converts a Set to a List, and coerces all list items into the correct type.
|
static Object |
DDBTypeUtils.coerceValueToExpectedType(Object value,
org.apache.arrow.vector.types.pojo.Field field,
org.apache.arrow.vector.types.Types.MinorType fieldType,
DDBRecordMetadata recordMetadata) |
Coerces the raw value from DynamoDB to normalized type
|
static Object |
DDBTypeUtils.convertArrowTypeIfNecessary(String columnName,
Object object,
DDBRecordMetadata recordMetadata) |
Converts certain Arrow POJOs to Java POJOs to make downstream conversion easier.
|
static String |
DDBPredicateUtils.generateFilterExpression(Set<String> columnsToIgnore,
Map<String,ValueSet> predicates,
List<software.amazon.awssdk.services.dynamodb.model.AttributeValue> accumulator,
IncrementingValueNameProducer valueNameProducer,
DDBRecordMetadata recordMetadata) |
Generates a combined filter expression for the given predicates.
|
static String |
DDBPredicateUtils.generateSingleColumnFilter(String originalColumnName,
ValueSet predicate,
List<software.amazon.awssdk.services.dynamodb.model.AttributeValue> accumulator,
IncrementingValueNameProducer valueNameProducer,
DDBRecordMetadata recordMetadata,
boolean columnIsSortKey) |
Generates a filter expression for a single column given a ValueSet predicate for that column. |
static Optional<Extractor> |
DDBTypeUtils.makeExtractor(org.apache.arrow.vector.types.pojo.Field field,
DDBRecordMetadata recordMetadata,
boolean caseInsensitive) |
Create the appropriate field extractor used for extracting field values from a DDB based on the field type.
|
static FieldWriterFactory |
DDBTypeUtils.makeFactory(org.apache.arrow.vector.types.pojo.Field field,
DDBRecordMetadata recordMetadata,
DynamoDBFieldResolver resolver,
boolean caseInsensitive) |
Since GeneratedRowWriter doesn't yet support complex types (STRUCT, LIST..etc) we use this to create our own
FieldWriters via a custom FieldWriterFactory.
|