EventPosition Clase

Paquete:

com.azure.messaging.eventhubs.models

Artefacto Maven:

com.azure:azure-messaging-eventhubs:5.18.7

• java.lang.Object
• • com.azure.messaging.eventhubs.models.EventPosition

public final class EventPosition

Define una posición de en el flujo de EventData partición del centro de eventos. La posición puede ser un desplazamiento, un número de secuencia o una hora puesta en cola en UTC.

Resumen del método

Modificador y tipo	Método y descripción
static EventPosition	earliest() Corresponde a la ubicación del primer evento presente en la partición.
boolean	equals(Object obj)
static EventPosition	fromEnqueuedTime(Instant enqueuedDateTime) Crea una posición en el objeto especificado Instant.
static EventPosition	fromOffset(long offset) Crea una posición para un evento en la partición en el desplazamiento proporcionado.
static EventPosition	fromSequenceNumber(long sequenceNumber) Crea una posición para un evento en la partición en el número de secuencia proporcionado.
static EventPosition	fromSequenceNumber(long sequenceNumber, boolean isInclusive) Crea una posición en el número de secuencia especificado.
Instant	getEnqueuedDateTime() Obtiene el instante, en UTC, desde el que se debe elegir el siguiente evento disponible.
String	getOffset() Obtiene la posición relativa del evento en el contexto de la secuencia.
Long	getSequenceNumber() Obtiene el número de secuencia del evento.
int	hashCode()
boolean	isInclusive() Obtiene el valor booleano de si se incluye el evento.
static EventPosition	latest() Corresponde al final de la partición, donde actualmente no hay más eventos en cola.
String	toString()

Métodos heredados de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Detalles del método

earliest

public static EventPosition earliest()

Corresponde a la ubicación del primer evento presente en la partición. Use esta posición para empezar a recibir desde el primer evento que se puso en cola en la partición que no ha expirado debido a la directiva de retención.

Devoluciones:

Un EventPosition conjunto en el inicio de una secuencia del centro de eventos.

equals

public boolean equals(Object obj)

Invalidaciones:

EventPosition.equals(Object obj)

Parámetros:

obj

fromEnqueuedTime

public static EventPosition fromEnqueuedTime(Instant enqueuedDateTime)

Crea una posición en el objeto especificado Instant. Corresponde a una instancia específica dentro de una partición para empezar a buscar un evento. El evento en cola después de que la solicitud enqueuedDateTime se convierta en la posición actual.

Parámetros:

enqueuedDateTime - El instante, en UTC, desde el que se debe elegir el siguiente evento disponible.

Devoluciones:

Objeto EventPosition.

fromOffset

public static EventPosition fromOffset(long offset)

Crea una posición para un evento en la partición en el desplazamiento proporcionado. El evento en ese desplazamiento no se incluirá. En su lugar, se devuelve el evento siguiente.

El desplazamiento es la posición relativa del evento en el contexto de la secuencia. El desplazamiento no debe considerarse un valor estable, ya que el mismo desplazamiento puede hacer referencia a un evento diferente, ya que los eventos alcanzan el límite de antigüedad para la retención y ya no son visibles dentro de la secuencia.

Parámetros:

offset - Desplazamiento del evento dentro de esa partición.

Devoluciones:

Objeto EventPosition.

fromSequenceNumber

public static EventPosition fromSequenceNumber(long sequenceNumber)

Crea una posición para un evento en la partición en el número de secuencia proporcionado. El evento con el número de secuencia no se incluirá. En su lugar, se devuelve el evento siguiente.

Parámetros:

sequenceNumber - es el número de secuencia del evento.

Devoluciones:

Objeto EventPosition.

fromSequenceNumber

public static EventPosition fromSequenceNumber(long sequenceNumber, boolean isInclusive)

Crea una posición en el número de secuencia especificado. Si isInclusive es true, se devuelve el evento con el mismo número de secuencia. De lo contrario, se recibe el siguiente evento de la secuencia.

Parámetros:

sequenceNumber - es el número de secuencia del evento.

isInclusive - Si es true, se incluirá el evento con ; sequenceNumber de lo contrario, se recibirá el siguiente evento.

Devoluciones:

Objeto EventPosition.

getEnqueuedDateTime

public Instant getEnqueuedDateTime()

Obtiene el instante, en UTC, desde el que se debe elegir el siguiente evento disponible.

Devoluciones:

El instante, en UTC, desde el que se debe elegir el siguiente evento disponible.

getOffset

public String getOffset()

Obtiene la posición relativa del evento en el contexto de la secuencia. El desplazamiento no debe considerarse un valor estable, ya que el mismo desplazamiento puede hacer referencia a un evento diferente, ya que los eventos alcanzan el límite de antigüedad para la retención y ya no son visibles dentro de la secuencia.

Devoluciones:

Desplazamiento del evento dentro de esa partición.

getSequenceNumber

public Long getSequenceNumber()

Obtiene el número de secuencia del evento.

Devoluciones:

Número de secuencia del evento.

hashCode

public int hashCode()

Invalidaciones:

EventPosition.hashCode()

isInclusive

public boolean isInclusive()

Obtiene el valor booleano de si se incluye el evento. Si es true, se incluirá el evento con ; sequenceNumber de lo contrario, se recibirá el siguiente evento.

Devoluciones:

Boolean si se recibirá el evento.

latest

public static EventPosition latest()

Corresponde al final de la partición, donde actualmente no hay más eventos en cola. Use esta posición para empezar a recibir del siguiente evento que se colocará en cola en la partición cuando receiveFromPartition(String partitionId, EventPosition startingPosition) se invoque.

Devoluciones:

Un EventPosition conjunto al final de una secuencia de Event Hubs y escucha los nuevos eventos.

toString

public String toString()

Invalidaciones:

EventPosition.toString()