Package io.deephaven.iceberg.util
Class UnboundResolver
java.lang.Object
io.deephaven.iceberg.util.UnboundResolver
- All Implemented Interfaces:
ResolverProvider
This is a resolver provider that will build a
Resolver
without needing to refer to an explicit Iceberg
Schema
. This is useful when the caller knows the definition of the table they want to load, and can provide
an explicit mapping between the Deephaven columns and Iceberg fields. This is provided as a convenience for cases
where explicitly building a Resolver
would be more tedious.-
Nested Class Summary
Nested Classes -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic UnboundResolver.Builder
builder()
abstract Map<String,
ColumnInstructions> The map from Deephaven column names to instructions for mapping to Iceberg columns.abstract TableDefinition
The table definition.schema()
The schema to use for inference.
-
Constructor Details
-
UnboundResolver
public UnboundResolver()
-
-
Method Details
-
builder
-
definition
The table definition.Callers should take care and only use
Partitioning
columns when they know the Iceberg table will always haveidentity
partitions for said columns. In the general case, Iceberg partitions may evolve over time, which can break the assumptions Deephaven makes about partitioning columns.- See Also:
-
columnInstructions
The map from Deephaven column names to instructions for mapping to Iceberg columns. Any columns fromdefinition()
not in this map will be assumed to be exact name matches for the fields in theSchema
.- See Also:
-
schema
The schema to use for inference. By default, isSchemaProvider.fromCurrent()
.
-