Interface InputSchemaUpdate.Builder

All Superinterfaces:
Buildable, CopyableBuilder<InputSchemaUpdate.Builder,InputSchemaUpdate>, SdkBuilder<InputSchemaUpdate.Builder,InputSchemaUpdate>, SdkPojo
Enclosing class:
InputSchemaUpdate
public static interface InputSchemaUpdate.Builder extends SdkPojo, CopyableBuilder<InputSchemaUpdate.Builder,InputSchemaUpdate>

  • Method Details

    • recordFormatUpdate

      InputSchemaUpdate.Builder recordFormatUpdate(RecordFormat recordFormatUpdate)

      Specifies the format of the records on the streaming source.

      Parameters:
      recordFormatUpdate - Specifies the format of the records on the streaming source.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • recordFormatUpdate

      default InputSchemaUpdate.Builder recordFormatUpdate(Consumer<RecordFormat.Builder> recordFormatUpdate)

      Specifies the format of the records on the streaming source.

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

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

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

    • recordEncodingUpdate

      InputSchemaUpdate.Builder recordEncodingUpdate(String recordEncodingUpdate)

      Specifies the encoding of the records in the streaming source. For example, UTF-8.

      Parameters:
      recordEncodingUpdate - Specifies the encoding of the records in the streaming source. For example, UTF-8.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • recordColumnUpdates

      InputSchemaUpdate.Builder recordColumnUpdates(Collection<RecordColumn> recordColumnUpdates)

      A list of RecordColumn objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.

      Parameters:
      recordColumnUpdates - A list of RecordColumn objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • recordColumnUpdates

      InputSchemaUpdate.Builder recordColumnUpdates(RecordColumn... recordColumnUpdates)

      A list of RecordColumn objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.

      Parameters:
      recordColumnUpdates - A list of RecordColumn objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • recordColumnUpdates

      InputSchemaUpdate.Builder recordColumnUpdates(Consumer<RecordColumn.Builder>... recordColumnUpdates)

      A list of RecordColumn objects. Each object describes the mapping of the streaming source element to the corresponding column in the in-application stream.

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

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

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