Interface GetPropertygraphStreamResponse.Builder

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

  • Method Details

    • lastEventId

      GetPropertygraphStreamResponse.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

      GetPropertygraphStreamResponse.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

      GetPropertygraphStreamResponse.Builder format(String format)

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

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

    • records

      GetPropertygraphStreamResponse.Builder records(Collection<PropertygraphRecord> 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

      GetPropertygraphStreamResponse.Builder records(PropertygraphRecord... 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

      GetPropertygraphStreamResponse.Builder records(Consumer<PropertygraphRecord.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 PropertygraphRecord.Builder avoiding the need to create one manually via PropertygraphRecord.builder().

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

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

    • totalRecords

      GetPropertygraphStreamResponse.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.