### Question:
PercolateTagProcessor implements StreamsProcessor { @Override public String getId() { return STREAMS_ID; } PercolateTagProcessor(ElasticsearchWriterConfiguration config);  PercolateTagProcessor(ElasticsearchWriterConfiguration config, String defaultPercolateField); ElasticsearchClientManager getManager(); void setManager(ElasticsearchClientManager manager); ElasticsearchConfiguration getConfig(); void setConfig(ElasticsearchWriterConfiguration config); Queue<StreamsDatum> getProcessorOutputQueue(); @Override String getId(); @Override List<StreamsDatum> process(StreamsDatum entry); @Override void prepare(Object configuration); @Override void cleanUp(); int numOfPercolateRules(); void createIndexIfMissing(String indexName); void addPercolateRule(PercolateQueryBuilder builder, String index); boolean writePercolateRules(); boolean removeOldTags(Set<String> ids, String index); Set<String> getActivePercolateTags(String index); boolean deleteOldQueries(String index); static final String STREAMS_ID; static final String TAGS_EXTENSION; }### Answer:
@Test public void percolateTagProcessorQueryBuilderTest() { PercolateTagProcessor.PercolateQueryBuilder percolateQueryBuilder = new PercolateTagProcessor.PercolateQueryBuilder(id, query, defaultPercolateField); assertEquals(id, percolateQueryBuilder.getId()); }