public final class DeleteQueryListener extends Object implements SnapshotResult, QueryListener
QueryListener
that provides a pull based iterator pattern for iterating over snapshot queries.
This should be used with snapshot queries only. Snapshots that hit the row limit are ended without any special notification.Constructor and Description |
---|
DeleteQueryListener() |
Modifier and Type | Method and Description |
---|---|
void |
close()
closes any resource associated with the snapshot result
|
void |
deleteBegin(BeginDeleteEvent event)
Event to indicate the start of delete query.
|
void |
deleteEnd(EndDeleteEvent event)
Event to indicate the delete query is complete.
|
void |
exceptionRaised(QueryExceptionEvent event)
Event when an exception occurs during the query.
|
List<Schema.Field> |
getFields()
Retrieves the fields describing the tuples that will be returned.
|
boolean |
hasNext()
See if there are more tuples to retrieve.
|
Tuple |
next()
Retrieves the next tuple in the result.
|
void |
queryClosed(QueryClosedEvent event)
Event when a query being listened to is closed.
|
void |
snapshotBegin(BeginSnapshotEvent event)
Event to indicate the start of the result snapshot.
|
void |
snapshotEnd(EndSnapshotEvent event)
Event to indicate the query snapshot is complete.
|
void |
tupleAdded(TupleAddedEvent event)
Event when a new tuple is added to the result.
|
void |
tupleRemoved(TupleRemovedEvent event)
Event when an existing tuple is removed from the result.
|
void |
tupleUpdated(TupleUpdatedEvent event)
Event when an existing tuple in the result is updated.
|
public List<Schema.Field> getFields() throws LiveViewException
getFields
in interface SnapshotResult
LiveViewException
- if exception occurs on the Querypublic boolean hasNext() throws LiveViewException
hasNext
in interface SnapshotResult
LiveViewException
public Tuple next() throws LiveViewException
next
in interface SnapshotResult
LiveViewException
- if exception occurs on the Querypublic void tupleAdded(TupleAddedEvent event)
tupleAdded
in interface QueryListener
event
- add eventpublic void tupleUpdated(TupleUpdatedEvent event)
tupleUpdated
in interface QueryListener
event
- update eventpublic void tupleRemoved(TupleRemovedEvent event)
tupleRemoved
in interface QueryListener
event
- remove eventpublic void deleteBegin(BeginDeleteEvent event)
deleteBegin
in interface QueryListener
event
- delete beginpublic void deleteEnd(EndDeleteEvent event)
deleteEnd
in interface QueryListener
event
- delete endpublic void exceptionRaised(QueryExceptionEvent event)
exceptionRaised
in interface QueryListener
event
- exception eventpublic void queryClosed(QueryClosedEvent event)
queryClosed
in interface QueryListener
event
- query closed eventpublic void close()
SnapshotResult
close
in interface SnapshotResult
close
in interface Closeable
close
in interface AutoCloseable
public void snapshotBegin(BeginSnapshotEvent event)
QueryListener
snapshotBegin
in interface QueryListener
event
- snapshot beginpublic void snapshotEnd(EndSnapshotEvent event)
QueryListener
snapshotEnd
in interface QueryListener
event
- snapshot end