IcebergWriteInstructions
The IcebergWriteInstructions
class provides instructions intended for writing Deephaven tables as partitions to Iceberg tables.
Syntax
IcebergWriteInstructions(
tables: Union[Table, Sequence[Table]],
partition_paths: Optional[Union[str, Sequence[str]]] = None,
)
Parameters
Parameter | Type | Description |
---|---|---|
tables | Union[Table, Sequence[Table]] | The Deephaven table(s) to write. |
partition_paths | Optional[Union[str, Sequence[str]]] | The partition paths where each table will be written. As an example, if the Iceberg table is partitioned by |
Methods
None.
Constructors
An IcebergWriteInstructions
is constructed directly from the class.
Examples
The following example creates IcebergWriteInstructions
for a single table to Iceberg:
from deephaven.experimental import iceberg
from deephaven import empty_table
source = empty_table(10).update(["X = i", "Y = 0.1 * X", "Z = Y ** 2"])
write_instructions = iceberg.IcebergWriteInstructions(source)
The following example creates IcebergWriteInstructions
for multiple tables to Iceberg:
from deephaven.experimental import iceberg
from deephaven import empty_table
source_1 = empty_table(10).update(["X = i", "Y = 0.1 * X", "Z = Y ** 2"])
source_2 = empty_table(10).update(["X = i + 100", "Y = 0.1 * X", "Z = sqrt(Y)"])
write_instructions = iceberg.IcebergWriteInstructions([source_1, source_2])