Interface S3HudiDirectTarget.Builder

All Superinterfaces:
Buildable, CopyableBuilder<S3HudiDirectTarget.Builder,S3HudiDirectTarget>, SdkBuilder<S3HudiDirectTarget.Builder,S3HudiDirectTarget>, SdkPojo
Enclosing class:
S3HudiDirectTarget

public static interface S3HudiDirectTarget.Builder extends SdkPojo, CopyableBuilder<S3HudiDirectTarget.Builder,S3HudiDirectTarget>
  • Method Details

    • name

      The name of the data target.

      Parameters:
      name - The name of the data target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • inputs

      The nodes that are inputs to the data target.

      Parameters:
      inputs - The nodes that are inputs to the data target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • inputs

      The nodes that are inputs to the data target.

      Parameters:
      inputs - The nodes that are inputs to the data target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • path

      The Amazon S3 path of your Hudi data source to write to.

      Parameters:
      path - The Amazon S3 path of your Hudi data source to write to.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • compression

      S3HudiDirectTarget.Builder compression(String compression)

      Specifies how the data is compressed. This is generally not necessary if the data has a standard file extension. Possible values are "gzip" and "bzip").

      Parameters:
      compression - Specifies how the data is compressed. This is generally not necessary if the data has a standard file extension. Possible values are "gzip" and "bzip").
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:
    • compression

      Specifies how the data is compressed. This is generally not necessary if the data has a standard file extension. Possible values are "gzip" and "bzip").

      Parameters:
      compression - Specifies how the data is compressed. This is generally not necessary if the data has a standard file extension. Possible values are "gzip" and "bzip").
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:
    • partitionKeys

      S3HudiDirectTarget.Builder partitionKeys(Collection<? extends Collection<String>> partitionKeys)

      Specifies native partitioning using a sequence of keys.

      Parameters:
      partitionKeys - Specifies native partitioning using a sequence of keys.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • partitionKeys

      S3HudiDirectTarget.Builder partitionKeys(Collection<String>... partitionKeys)

      Specifies native partitioning using a sequence of keys.

      Parameters:
      partitionKeys - Specifies native partitioning using a sequence of keys.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • format

      Specifies the data output format for the target.

      Parameters:
      format - Specifies the data output format for the target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:
    • format

      Specifies the data output format for the target.

      Parameters:
      format - Specifies the data output format for the target.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:
    • additionalOptions

      S3HudiDirectTarget.Builder additionalOptions(Map<String,String> additionalOptions)

      Specifies additional connection options for the connector.

      Parameters:
      additionalOptions - Specifies additional connection options for the connector.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • schemaChangePolicy

      S3HudiDirectTarget.Builder schemaChangePolicy(DirectSchemaChangePolicy schemaChangePolicy)

      A policy that specifies update behavior for the crawler.

      Parameters:
      schemaChangePolicy - A policy that specifies update behavior for the crawler.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • schemaChangePolicy

      default S3HudiDirectTarget.Builder schemaChangePolicy(Consumer<DirectSchemaChangePolicy.Builder> schemaChangePolicy)

      A policy that specifies update behavior for the crawler.

      This is a convenience method that creates an instance of the DirectSchemaChangePolicy.Builder avoiding the need to create one manually via DirectSchemaChangePolicy.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to schemaChangePolicy(DirectSchemaChangePolicy).

      Parameters:
      schemaChangePolicy - a consumer that will call methods on DirectSchemaChangePolicy.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also: