this method should be called from the com.datatorrent.api.operator #teardown method so that thequerymanagersynchronous can correctly initialize its internal state . concode_field_sep QueryExecutor<QUERY_TYPE,META_QUERY,QUEUE_CONTEXT,RESULT> queryExecutor concode_elem_sep QueueManager<QUERY_TYPE,META_QUERY,QUEUE_CONTEXT> queryQueueManager concode_field_sep boolean enqueue concode_elem_sep void beginWindow concode_elem_sep RESULT process concode_elem_sep void setQueryQueueManager concode_elem_sep void setup concode_elem_sep void endWindow concode_elem_sep QueryManagerSynchronous<QUERY_TYPE,META_QUERY,QUEUE_CONTEXT,RESULT> newInstance concode_elem_sep QueryManagerSynchronous<QUERY_TYPE,META_QUERY,QUEUE_CONTEXT,RESULT> newInstance concode_elem_sep void setQueryExecutor
void function ( ) { queryQueueManager . teardown ( ) ; }