@ Synchronized public SegmentOutputStream getSegmentOutputStreamForKey ( String routingKey ) { if ( currentSegments == null ) { return null ; } return writers . get ( getSegmentForEvent ( routingKey ) ) ; }
Selects which segment an event should be written to .