public OffsetCommitTrigger getOffsetCommitTrigger ( ) { for ( Pipe pipe : pipes ) { Stage stage = pipe . getStage ( ) . getStage ( ) ; if ( stage instanceof Target && stage instanceof OffsetCommitTrigger ) { return ( OffsetCommitTrigger ) stage ; } } return null ; }
Retrieve OffsetCommitTrigger pipe .