EventPosition Classe

Pacote:

com.azure.messaging.eventhubs.models

Artefato Maven:

com.azure:azure-messaging-eventhubs:5.18.7

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

public final class EventPosition

Define uma posição de um EventData no fluxo de partição do Hub de Eventos. A posição pode ser um deslocamento, número de sequência ou hora enfileirada em UTC.

Resumo do método

Modificador e tipo	Método e descrição
static EventPosition	earliest() Corresponde ao local do primeiro evento presente na partição.
boolean	equals(Object obj)
static EventPosition	fromEnqueuedTime(Instant enqueuedDateTime) Cria uma posição no determinado Instant.
static EventPosition	fromOffset(long offset) Cria uma posição para um evento na partição no deslocamento fornecido.
static EventPosition	fromSequenceNumber(long sequenceNumber) Cria uma posição para um evento na partição no número de sequência fornecido.
static EventPosition	fromSequenceNumber(long sequenceNumber, boolean isInclusive) Cria uma posição no número de sequência especificado.
Instant	getEnqueuedDateTime() Obtém o instante, em UTC, do qual o próximo evento disponível deve ser escolhido.
String	getOffset() Obtém a posição relativa do evento no contexto do fluxo.
Long	getSequenceNumber() Obtém o número de sequência do evento.
int	hashCode()
boolean	isInclusive() Obtém o valor booliano de se o evento estiver incluído.
static EventPosition	latest() Corresponde ao final da partição, em que não há mais eventos enfileirados no momento.
String	toString()

Métodos herdados de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Detalhes do método

earliest

public static EventPosition earliest()

Corresponde ao local do primeiro evento presente na partição. Use essa posição para começar a receber do primeiro evento que foi enfileirado na partição que não expirou devido à política de retenção.

Retornos:

Um EventPosition definido como o início de um fluxo do Hub de Eventos.

equals

public boolean equals(Object obj)

Substituições:

EventPosition.equals(Object obj)

Parâmetros:

obj

fromEnqueuedTime

public static EventPosition fromEnqueuedTime(Instant enqueuedDateTime)

Cria uma posição no determinado Instant. Corresponde a uma instância específica dentro de uma partição para começar a procurar um evento. O evento enfileirado após o solicitado enqueuedDateTime se torna a posição atual.

Parâmetros:

enqueuedDateTime - O instante, em UTC, do qual o próximo evento disponível deve ser escolhido.

Retornos:

Um objeto EventPosition.

fromOffset

public static EventPosition fromOffset(long offset)

Cria uma posição para um evento na partição no deslocamento fornecido. O evento nesse deslocamento não será incluído. Em vez disso, o próximo evento é retornado.

O deslocamento é a posição relativa do evento no contexto do fluxo. O deslocamento não deve ser considerado um valor estável, pois o mesmo deslocamento pode se referir a um evento diferente, pois os eventos atingem o limite de idade para retenção e não estão mais visíveis dentro do fluxo.

Parâmetros:

offset - O deslocamento do evento dentro dessa partição.

Retornos:

Um objeto EventPosition.

fromSequenceNumber

public static EventPosition fromSequenceNumber(long sequenceNumber)

Cria uma posição para um evento na partição no número de sequência fornecido. O evento com o número de sequência não será incluído. Em vez disso, o próximo evento é retornado.

Parâmetros:

sequenceNumber - é o número de sequência do evento.

Retornos:

Um objeto EventPosition.

fromSequenceNumber

public static EventPosition fromSequenceNumber(long sequenceNumber, boolean isInclusive)

Cria uma posição no número de sequência especificado. Se isInclusive for true, o evento com o mesmo número de sequência será retornado. Caso contrário, o próximo evento na sequência será recebido.

Parâmetros:

sequenceNumber - é o número de sequência do evento.

isInclusive - Se for true, o evento com o sequenceNumber será incluído; caso contrário, o próximo evento será recebido.

Retornos:

Um objeto EventPosition.

getEnqueuedDateTime

public Instant getEnqueuedDateTime()

Obtém o instante, em UTC, do qual o próximo evento disponível deve ser escolhido.

Retornos:

O instante, em UTC, do qual o próximo evento disponível deve ser escolhido.

getOffset

public String getOffset()

Obtém a posição relativa do evento no contexto do fluxo. O deslocamento não deve ser considerado um valor estável, pois o mesmo deslocamento pode se referir a um evento diferente, pois os eventos atingem o limite de idade para retenção e não estão mais visíveis dentro do fluxo.

Retornos:

O deslocamento do evento dentro dessa partição.

getSequenceNumber

public Long getSequenceNumber()

Obtém o número de sequência do evento.

Retornos:

O número de sequência do evento.

hashCode

public int hashCode()

Substituições:

EventPosition.hashCode()

isInclusive

public boolean isInclusive()

Obtém o valor booliano de se o evento estiver incluído. Se for true, o evento com o sequenceNumber será incluído; caso contrário, o próximo evento será recebido.

Retornos:

O booliano se o evento for recebido.

latest

public static EventPosition latest()

Corresponde ao final da partição, em que não há mais eventos enfileirados no momento. Use essa posição para começar a receber do próximo evento a ser enfileirado na partição quando receiveFromPartition(String partitionId, EventPosition startingPosition) invocado.

Retornos:

Um EventPosition conjunto até o final de um fluxo de Hubs de Eventos e escuta novos eventos.

toString

public String toString()

Substituições:

EventPosition.toString()