Interface GetSparqlStreamResponse.Builder

All Superinterfaces:
AwsResponse.Builder, Buildable, CopyableBuilder<GetSparqlStreamResponse.Builder,GetSparqlStreamResponse>, NeptunedataResponse.Builder, SdkBuilder<GetSparqlStreamResponse.Builder,GetSparqlStreamResponse>, SdkPojo, SdkResponse.Builder
Enclosing class:
GetSparqlStreamResponse
@Mutable @NotThreadSafe public static interface GetSparqlStreamResponse.Builder extends NeptunedataResponse.Builder, SdkPojo, CopyableBuilder<GetSparqlStreamResponse.Builder,GetSparqlStreamResponse>

  • Method Details

    • lastEventId

      GetSparqlStreamResponse.Builder lastEventId(Map<String,String> lastEventId)

      Sequence identifier of the last change in the stream response.

      An event ID is composed of two fields: a commitNum, which identifies a transaction that changed the graph, and an opNum, which identifies a specific operation within that transaction:

      Parameters:
      lastEventId - Sequence identifier of the last change in the stream response.

      An event ID is composed of two fields: a commitNum, which identifies a transaction that changed the graph, and an opNum, which identifies a specific operation within that transaction:

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • lastTrxTimestampInMillis

      GetSparqlStreamResponse.Builder lastTrxTimestampInMillis(Long lastTrxTimestampInMillis)

      The time at which the commit for the transaction was requested, in milliseconds from the Unix epoch.

      Parameters:
      lastTrxTimestampInMillis - The time at which the commit for the transaction was requested, in milliseconds from the Unix epoch.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • format

      GetSparqlStreamResponse.Builder format(String format)

      Serialization format for the change records being returned. Currently, the only supported value is NQUADS.

      Parameters:
      format - Serialization format for the change records being returned. Currently, the only supported value is NQUADS.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • records

      GetSparqlStreamResponse.Builder records(Collection<SparqlRecord> records)

      An array of serialized change-log stream records included in the response.

      Parameters:
      records - An array of serialized change-log stream records included in the response.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • records

      GetSparqlStreamResponse.Builder records(SparqlRecord... records)

      An array of serialized change-log stream records included in the response.

      Parameters:
      records - An array of serialized change-log stream records included in the response.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • records

      GetSparqlStreamResponse.Builder records(Consumer<SparqlRecord.Builder>... records)

      An array of serialized change-log stream records included in the response.

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

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

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

    • totalRecords

      GetSparqlStreamResponse.Builder totalRecords(Integer totalRecords)

      The total number of records in the response.

      Parameters:
      totalRecords - The total number of records in the response.
      Returns:
      Returns a reference to this object so that method calls can be chained together.