@ Override public final void insert ( ClusterName targetCluster , TableMetadata targetTable , Row row , boolean isNotExists ) throws UnsupportedException , ExecutionException { try { connectionHandler . startJob ( targetCluster . getName ( ) ) ; if ( logger . isDebugEnabled ( ) ) { logger . debug ( "Inserting one row in table [" + targetTable . getName ( ) . getName ( ) + "] in cluster [" + targetCluster . getName ( ) + "]" ) ; } insert ( targetTable , row , isNotExists , connectionHandler . getConnection ( targetCluster . getName ( ) ) ) ; if ( logger . isDebugEnabled ( ) ) { logger . debug ( "One row has been inserted successfully in table [" + targetTable . getName ( ) . getName ( ) + "] in cluster [" + targetCluster . getName ( ) + "]" ) ; } } finally { connectionHandler . endJob ( targetCluster . getName ( ) ) ; } }
Insert a single row in a table .