@InterfaceStability.Evolving public class ListTransactionsOptions extends AbstractOptions<ListTransactionsOptions>
Admin.listTransactions()
.
The API of this class is evolving, see Admin
for details.Constructor and Description |
---|
ListTransactionsOptions() |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
long |
filteredDuration()
Returns the duration ms value being filtered.
|
Set<Long> |
filteredProducerIds()
Returns the set of producerIds that are being filtered or empty if none have been specified.
|
Set<TransactionState> |
filteredStates()
Returns the set of states to be filtered or empty if no states have been specified.
|
ListTransactionsOptions |
filterOnDuration(long durationMs)
Filter only the transactions that are running longer than the specified duration.
|
ListTransactionsOptions |
filterProducerIds(Collection<Long> producerIdFilters)
Filter only the transactions from producers in a specific set of producerIds.
|
ListTransactionsOptions |
filterStates(Collection<TransactionState> states)
Filter only the transactions that are in a specific set of states.
|
int |
hashCode() |
String |
toString() |
timeoutMs, timeoutMs
public ListTransactionsOptions filterStates(Collection<TransactionState> states)
states
- the set of states to filter bypublic ListTransactionsOptions filterProducerIds(Collection<Long> producerIdFilters)
producerIdFilters
- the set of producerIds to filter bypublic ListTransactionsOptions filterOnDuration(long durationMs)
durationMs
- the duration in milliseconds to filter bypublic Set<TransactionState> filteredStates()
public Set<Long> filteredProducerIds()
public long filteredDuration()