Interface SnapshotTable

    • Method Detail

      • as

        SnapshotTable as​(java.lang.String destTableIdent)
        Sets the table identifier for the newly created Iceberg table.
        Parameters:
        destTableIdent - the destination table identifier
        Returns:
        this for method chaining
      • tableLocation

        SnapshotTable tableLocation​(java.lang.String location)
        Sets the table location for the newly created Iceberg table.
        Parameters:
        location - a table location
        Returns:
        this for method chaining
      • tableProperties

        SnapshotTable tableProperties​(java.util.Map<java.lang.String,​java.lang.String> properties)
        Sets table properties in the newly created Iceberg table. Any properties with the same key name will be overwritten.
        Parameters:
        properties - a map of properties to be included
        Returns:
        this for method chaining
      • tableProperty

        SnapshotTable tableProperty​(java.lang.String key,
                                    java.lang.String value)
        Sets a table property in the newly created Iceberg table. Any properties with the same key name will be overwritten.
        Parameters:
        key - the key of the property to add
        value - the value of the property to add
        Returns:
        this for method chaining
      • executeWith

        default SnapshotTable executeWith​(java.util.concurrent.ExecutorService service)
        Sets the executor service to use for parallel file reading. The default is not using executor service.
        Parameters:
        service - executor service
        Returns:
        this for method chaining