refresh the list of sinks . concode_field_sep Connection conn concode_elem_sep float DEFAULT_REPLICATION_SOURCE_RATIO concode_elem_sep int DEFAULT_BAD_SINK_THRESHOLD concode_elem_sep ServerName serverName concode_elem_sep Log LOG concode_elem_sep int badSinkThreshold concode_elem_sep List<ServerName> sinks concode_elem_sep long lastUpdateToPeers concode_elem_sep Random random concode_elem_sep HBaseReplicationEndpoint endpoint concode_elem_sep String peerClusterId concode_elem_sep Map<ServerName,Integer> badReportCounts concode_elem_sep AdminService.BlockingInterface regionServer concode_elem_sep float ratio concode_field_sep AdminService.BlockingInterface getRegionServer concode_elem_sep void reportBadSink concode_elem_sep void reportSinkSuccess concode_elem_sep int getNumSinks concode_elem_sep List<ServerName> getSinksForTesting concode_elem_sep ServerName getServerName concode_elem_sep SinkPeer getReplicationSink
void function ( ) { List < ServerName > loc0 = endpoint . getRegionServers ( ) ; Collections . shuffle ( loc0 , random ) ; int loc1 = ( int ) Math . ceil ( loc0 . size ( ) * ratio ) ; sinks = loc0 . subList ( 0 , loc1 ) ; lastUpdateToPeers = System . currentTimeMillis ( ) ; badReportCounts . clear ( ) ; }