protected void sendCollectorDataPartitionReplyMsg ( Serializable data ) { if ( logger . isLoggable ( Level . FINE ) ) { logger . fine ( "Sending collector partition data: " + data + " to analyzer queue: " + getPartitionReplyQueue ( ) ) ; } PartitionReplyMsg msg = new PartitionReplyMsg ( PartitionReplyMsgType . PARTITION_COLLECTOR_DATA ) . setCollectorData ( serializeToByteArray ( data ) ) ; getPartitionReplyQueue ( ) . add ( msg ) ; }
Send sub - job partition thread data back to top - level thread via analyzerStatusQueue .