Interface CatalogSource.Builder

  • Method Details

    • name

      The name of the data store.

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

      CatalogSource.Builder database(String database)

      The name of the database to read from.

      Parameters:
      database - The name of the database to read from.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • table

      The name of the table in the database to read from.

      Parameters:
      table - The name of the table in the database to read from.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • partitionPredicate

      CatalogSource.Builder partitionPredicate(String partitionPredicate)

      Partitions satisfying this predicate are deleted. Files within the retention period in these partitions are not deleted.

      Parameters:
      partitionPredicate - Partitions satisfying this predicate are deleted. Files within the retention period in these partitions are not deleted.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • outputSchemas

      CatalogSource.Builder outputSchemas(Collection<GlueSchema> outputSchemas)

      Specifies the data schema for the catalog source.

      Parameters:
      outputSchemas - Specifies the data schema for the catalog source.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • outputSchemas

      CatalogSource.Builder outputSchemas(GlueSchema... outputSchemas)

      Specifies the data schema for the catalog source.

      Parameters:
      outputSchemas - Specifies the data schema for the catalog source.
      Returns:
      Returns a reference to this object so that method calls can be chained together.
    • outputSchemas

      CatalogSource.Builder outputSchemas(Consumer<GlueSchema.Builder>... outputSchemas)

      Specifies the data schema for the catalog source.

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

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to outputSchemas(List<GlueSchema>).

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