Archiving processed tweets to Cassandra

spring-pu.xml

<os-archive:archive-container 
   giga-space="gigaSpace" concurrent-consumers="2" batch-size="100" >
  <os-archive:archive-handler ref="cassandra" />
  <os-archive:tx-support tx-manager="transactionManager"/>
  <os-core:template ref="archiverFilter" />
  <os-archive:exception-handler ref="archiverFilter"/>
</os-archive:archive-container>
  
<bean id="archiverFilter" class="org.openspaces.bigdata.processor.TweetArchiveFilter" /> 

TweetArchiveFilter.java

public class TweetArchiveFilter implements EventTemplateProvider {

 public SQLQuery<SpaceDocument> getTemplate() {
    return new SQLQuery<SpaceDocument>("Tweet", "Processed = ?", true);
 }
}