public class BlobChangefeedClient extends Object
BlobChangefeedClientBuilder
Modifier and Type | Method and Description |
---|---|
BlobChangefeedPagedIterable |
getEvents()
Returns a lazy loaded list of changefeed events for this account.
|
BlobChangefeedPagedIterable |
getEvents(OffsetDateTime startTime,
OffsetDateTime endTime)
Returns a lazy loaded list of changefeed events for this account.
|
BlobChangefeedPagedIterable |
getEvents(OffsetDateTime startTime,
OffsetDateTime endTime,
com.azure.core.util.Context context)
Returns a lazy loaded list of changefeed events for this account.
|
BlobChangefeedPagedIterable |
getEvents(String cursor)
Returns a lazy loaded list of changefeed events for this account.
|
BlobChangefeedPagedIterable |
getEvents(String cursor,
com.azure.core.util.Context context)
Returns a lazy loaded list of changefeed events for this account.
|
public BlobChangefeedPagedIterable getEvents()
BlobChangefeedPagedIterable
can be consumed through while new items are automatically retrieved as needed.
Changefeed events are returned in approximate temporal order.
For more information, see the Azure Docs.
Code Samples
client.getEvents().forEach(event ->
System
.out.printf("Topic: %s, Subject: %s%n", event.getTopic(), event.getSubject()));
public BlobChangefeedPagedIterable getEvents(OffsetDateTime startTime, OffsetDateTime endTime)
BlobChangefeedPagedIterable
can be consumed through while new items are automatically retrieved as needed.
Changefeed events are returned in approximate temporal order.
For more information, see the Azure Docs.
Code Samples
OffsetDateTime
startTime =OffsetDateTime
.MIN;OffsetDateTime
endTime =OffsetDateTime
.now(); client.getEvents(startTime, endTime).forEach(event ->System
.out.printf("Topic: %s, Subject: %s%n", event.getTopic(), event.getSubject()));
startTime
- Filters the results to return events approximately after the start time. Note: A few events
belonging to the previous hour can also be returned. A few events belonging to this hour can be missing; to
ensure all events from the hour are returned, round the start time down by an hour.endTime
- Filters the results to return events approximately before the end time. Note: A few events
belonging to the next hour can also be returned. A few events belonging to this hour can be missing; to ensure
all events from the hour are returned, round the end time up by an hour.public BlobChangefeedPagedIterable getEvents(OffsetDateTime startTime, OffsetDateTime endTime, com.azure.core.util.Context context)
BlobChangefeedPagedIterable
can be consumed through while new items are automatically retrieved as needed.
Changefeed events are returned in approximate temporal order.
For more information, see the Azure Docs.
Code Samples
OffsetDateTime
startTime =OffsetDateTime
.MIN;OffsetDateTime
endTime =OffsetDateTime
.now(); client.getEvents(startTime, endTime, newContext
("key", "value")).forEach(event ->System
.out.printf("Topic: %s, Subject: %s%n", event.getTopic(), event.getSubject()));
startTime
- Filters the results to return events approximately after the start time. Note: A few events
belonging to the previous hour can also be returned. A few events belonging to this hour can be missing; to
ensure all events from the hour are returned, round the start time down by an hour.endTime
- Filters the results to return events approximately before the end time. Note: A few events
belonging to the next hour can also be returned. A few events belonging to this hour can be missing; to ensure
all events from the hour are returned, round the end time up by an hour.context
- Additional context that is passed through the Http pipeline during the service call.public BlobChangefeedPagedIterable getEvents(String cursor)
BlobChangefeedPagedIterable
can be consumed through while new items are automatically retrieved as needed.
Changefeed events are returned in approximate temporal order.
For more information, see the Azure Docs.
Code Samples
String
cursor = "cursor"; client.getEvents(cursor).forEach(event ->System
.out.printf("Topic: %s, Subject: %s%n", event.getTopic(), event.getSubject()));
cursor
- Identifies the portion of the events to be returned with the next get operation. Events that
take place after the event identified by the cursor will be returned.public BlobChangefeedPagedIterable getEvents(String cursor, com.azure.core.util.Context context)
BlobChangefeedPagedIterable
can be consumed through while new items are automatically retrieved as needed.
Changefeed events are returned in approximate temporal order.
For more information, see the Azure Docs.
Code Samples
String
cursor = "cursor"; client.getEvents(cursor, newContext
("key", "value")).forEach(event ->System
.out.printf("Topic: %s, Subject: %s%n", event.getTopic(), event.getSubject()));
cursor
- Identifies the portion of the events to be returned with the next get operation. Events that
take place after the event identified by the cursor will be returned.context
- Additional context that is passed through the Http pipeline during the service call.Copyright © 2021 Microsoft Corporation. All rights reserved.