@Test public void testGetDriverConfigBundle() { when(resourceRequests.readDriver()).thenReturn(driverBean(driver())); client.getDriverConfigBundle(); client.getDriverConfig(); verify(resourceRequests, times(1)).readDriver(); }
public ResourceBundle getDriverConfigBundle() { if(driverConfigBundle != null) { return driverConfigBundle; } retrieveAndCacheDriver(); return driverConfigBundle; }
SqoopClient { public ResourceBundle getDriverConfigBundle() { if(driverConfigBundle != null) { return driverConfigBundle; } retrieveAndCacheDriver(); return driverConfigBundle; } }
SqoopClient { public ResourceBundle getDriverConfigBundle() { if(driverConfigBundle != null) { return driverConfigBundle; } retrieveAndCacheDriver(); return driverConfigBundle; } SqoopClient(String serverUrl); }
SqoopClient { public ResourceBundle getDriverConfigBundle() { if(driverConfigBundle != null) { return driverConfigBundle; } retrieveAndCacheDriver(); return driverConfigBundle; } SqoopClient(String serverUrl); void setServerUrl(String serverUrl); void setSqoopRequests(SqoopResourceRequests requests); void clearCache(); MConnector getConnector(long cid); MConnector getConnector(String connectorName); Collection<MConnector> getConnectors(); ResourceBundle getConnectorConfigBundle(long connectorId); MDriverConfig getDriverConfig(); MDriver getDriver(); ResourceBundle getDriverConfigBundle(); MLink createLink(long connectorId); MLink createLink(String connectorName); MLink getLink(long linkId); List<MLink> getLinks(); Status saveLink(MLink link); Status updateLink(MLink link); void enableLink(long linkId, boolean enabled); void deleteLink(long linkId); MJob createJob(long fromLinkId, long toLinkId); MJob getJob(long jobId); List<MJob> getJobs(); List<MJob> getJobsByConnector(long cId); Status saveJob(MJob job); Status updateJob(MJob job); void enableJob(long jid, boolean enabled); void deleteJob(long jobId); MSubmission startJob(long jobId); MSubmission startJob(long jobId, SubmissionCallback callback, long pollTime); MSubmission stopJob(long jid); MSubmission getJobStatus(long jid); List<MSubmission> getSubmissions(); List<MSubmission> getSubmissionsForJob(long jobId); List<MRole> getRoles(); void createRole(MRole role); void dropRole(MRole role); void grantRole(List<MRole> roles, List<MPrincipal> principals); void revokeRole(List<MRole> roles, List<MPrincipal> principals); List<MRole> getRolesByPrincipal(MPrincipal principal); List<MPrincipal> getPrincipalsByRole(MRole role); void grantPrivilege(List<MPrincipal> principals, List<MPrivilege> privileges); void revokePrivilege(List<MPrincipal> principals, List<MPrivilege> privileges); List<MPrivilege> getPrivilegesByPrincipal(MPrincipal principal, MResource resource); Token<?>[] addDelegationTokens(String renewer,
                                        Credentials credentials); }
SqoopClient { public ResourceBundle getDriverConfigBundle() { if(driverConfigBundle != null) { return driverConfigBundle; } retrieveAndCacheDriver(); return driverConfigBundle; } SqoopClient(String serverUrl); void setServerUrl(String serverUrl); void setSqoopRequests(SqoopResourceRequests requests); void clearCache(); MConnector getConnector(long cid); MConnector getConnector(String connectorName); Collection<MConnector> getConnectors(); ResourceBundle getConnectorConfigBundle(long connectorId); MDriverConfig getDriverConfig(); MDriver getDriver(); ResourceBundle getDriverConfigBundle(); MLink createLink(long connectorId); MLink createLink(String connectorName); MLink getLink(long linkId); List<MLink> getLinks(); Status saveLink(MLink link); Status updateLink(MLink link); void enableLink(long linkId, boolean enabled); void deleteLink(long linkId); MJob createJob(long fromLinkId, long toLinkId); MJob getJob(long jobId); List<MJob> getJobs(); List<MJob> getJobsByConnector(long cId); Status saveJob(MJob job); Status updateJob(MJob job); void enableJob(long jid, boolean enabled); void deleteJob(long jobId); MSubmission startJob(long jobId); MSubmission startJob(long jobId, SubmissionCallback callback, long pollTime); MSubmission stopJob(long jid); MSubmission getJobStatus(long jid); List<MSubmission> getSubmissions(); List<MSubmission> getSubmissionsForJob(long jobId); List<MRole> getRoles(); void createRole(MRole role); void dropRole(MRole role); void grantRole(List<MRole> roles, List<MPrincipal> principals); void revokeRole(List<MRole> roles, List<MPrincipal> principals); List<MRole> getRolesByPrincipal(MPrincipal principal); List<MPrincipal> getPrincipalsByRole(MRole role); void grantPrivilege(List<MPrincipal> principals, List<MPrivilege> privileges); void revokePrivilege(List<MPrincipal> principals, List<MPrivilege> privileges); List<MPrivilege> getPrivilegesByPrincipal(MPrincipal principal, MResource resource); Token<?>[] addDelegationTokens(String renewer,
                                        Credentials credentials);  }