Interface SparqlRecord.Builder

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

  • Method Details

    • commitTimestampInMillis

      SparqlRecord.Builder commitTimestampInMillis(Long commitTimestampInMillis)

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

      Parameters:
      commitTimestampInMillis - 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.

    • eventId

      SparqlRecord.Builder eventId(Map<String,String> eventId)

      The sequence identifier of the stream change record.

      Parameters:
      eventId - The sequence identifier of the stream change record.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • data

      SparqlRecord.Builder data(SparqlData data)

      The serialized SPARQL change record. The serialization formats of each record are described in more detail in Serialization Formats in Neptune Streams.

      Parameters:
      data - The serialized SPARQL change record. The serialization formats of each record are described in more detail in Serialization Formats in Neptune Streams.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • data

      default SparqlRecord.Builder data(Consumer<SparqlData.Builder> data)

      The serialized SPARQL change record. The serialization formats of each record are described in more detail in Serialization Formats in Neptune Streams.

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

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

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

    • op

      SparqlRecord.Builder op(String op)

      The operation that created the change.

      Parameters:
      op - The operation that created the change.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • isLastOp

      SparqlRecord.Builder isLastOp(Boolean isLastOp)

      Only present if this operation is the last one in its transaction. If present, it is set to true. It is useful for ensuring that an entire transaction is consumed.

      Parameters:
      isLastOp - Only present if this operation is the last one in its transaction. If present, it is set to true. It is useful for ensuring that an entire transaction is consumed.
      Returns:
      Returns a reference to this object so that method calls can be chained together.