co.cask.cdap.messaging.store

Class TransactionMessageFilter

java.lang.Object

co.cask.cdap.messaging.store.MessageFilter<MessageTable.Entry>

co.cask.cdap.messaging.store.TransactionMessageFilter

All Implemented Interfaces:

com.google.common.base.Function<MessageTable.Entry,MessageFilter.Result>

public class TransactionMessageFilter
extends MessageFilter<MessageTable.Entry>

A MessageFilter that filter MessageTable.Entry based on a given transaction.

Nested Class Summary

Nested classes/interfaces inherited from class co.cask.cdap.messaging.store.MessageFilter

MessageFilter.Result

Constructor Summary

Constructors

Constructor and Description
TransactionMessageFilter(org.apache.tephra.Transaction transaction)

Method Summary

Modifier and Type	Method and Description
MessageFilter.Result	apply(MessageTable.Entry entry)
MessageFilter.Result	filter(long txWritePtr)

Methods inherited from class co.cask.cdap.messaging.store.MessageFilter

alwaysAccept

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.google.common.base.Function

equals

Constructor Detail

TransactionMessageFilter

public TransactionMessageFilter(org.apache.tephra.Transaction transaction)

Method Detail

apply

public MessageFilter.Result apply(MessageTable.Entry entry)

Specified by:

apply in interface com.google.common.base.Function<MessageTable.Entry,MessageFilter.Result>

Specified by:

apply in class MessageFilter<MessageTable.Entry>

filter

public MessageFilter.Result filter(long txWritePtr)