@ Override public Object put ( List < Map . Entry > batch ) throws InterruptedException { if ( initializeClusterSource ( ) ) { return clusterSource . put ( batch ) ; } return null ; }
Writes batch of data to the source