轨迹_b428

JobManager类 JobManager类用于对提交的任务进行管理。 初始化 JobManager初始化的过程主要是从配置文件(server/conf/sqoop.pro...

轨迹_b428

JobManager类 JobManager类用于对提交的任务进行管理。 初始化 JobManager初始化的过程主要是从配置文件(server/conf/sqoop.pro...

轨迹_b428

AuthorizationManager类 AuthorizationManager类用于初始化AuthorizationHandler， 并对其进行管理。起初始化源代码如下...

轨迹_b428

你好权限验证这一段具体的权限是在哪里验证？？ 我看方法最后的调用也只是日志打印
// Authorization check
AuthorizationEngine.startJob(ctx.getUserName(), jobName);
public static void startJob(String doUserName, String jobName) throws SqoopException {
checkPrivilege(doUserName, getPrivilege(MResource.TYPE.JOB, jobName, MPrivilege.ACTION.WRITE));
}
public void checkPrivileges(MPrincipal principal, List<MPrivilege> privileges) throws SqoopException {
LOG.debug("Check privilege in default authorization validator: always valid");
LOG.debug("principal: " + principal.toString());
for (MPrivilege privilege : privileges) {
LOG.debug("privilege: " + privilege.toString());
}
} 这一段也没有具体的权限验证的方式呀 只是做了个log打印

AuthorizationManager源码分析

AuthorizationManager类 AuthorizationManager类用于初始化AuthorizationHandler， 并对其进行管理。起初始化源代码如下...

zjlearn

1397 2 1 1

轨迹_b428

Repository 里是保存了Links, Jobs 的状态更新吗 ？ 看到CommonRepositoryHandler 中
public void updateSubmission(MSubmission submission, Connection conn) { result = stmt.executeUpdate(); 中这个connection 参数是 那个数据库的conn ？？ 它会在那个数据库持久化？？

RepositoryManager源码分析

RepositoryManager类 RepositoryManager类负责对RepositoryProvider进行管理， 主要的功能为从配置文件中“server/con...

zjlearn

729 1 1

轨迹_b428

这个AuthorizationRequestHandler 在调用createRole 时 创建的role 保存或者持久化在了那里， 我看public void createRole(MRole role) throws SqoopException {
LOG.debug("Create role in default authorization access controller: empty function");
LOG.debug("role: " + role.toString());
} 只是打印了一条日志，并没有保存操作

AuthorizationManager源码分析

AuthorizationManager类 AuthorizationManager类用于初始化AuthorizationHandler， 并对其进行管理。起初始化源代码如下...

zjlearn

1397 2 1 1

轨迹_b428

AuthorizationManager类 AuthorizationManager类用于初始化AuthorizationHandler， 并对其进行管理。起初始化源代码如下...

轨迹_b428

RepositoryManager类 RepositoryManager类负责对RepositoryProvider进行管理， 主要的功能为从配置文件中“server/con...

轨迹_b428

AuditLoggerManager类

轨迹_b428

您好，这里看到 GenericJdbcExtractor 从From数据源相应的partition中拿到数据，
然后获取 DateWriter 方法，context.getDataWriter().writeArrayRecord(array) 这个方法将数据写到了那里？？ 还有GenericJdbcLoader 的load在哪里执行， 它写的数据是extractor读出的数据吗？ 谢谢

Job运行分析

本文我们用来分析Job的启动过程。下面我们按照job在server端的提交过程进行分析 JobRequestHandler JobRequestHandler负责处理关于jo...

zjlearn

851 1 1

轨迹_b428

本文我们用来分析Job的启动过程。下面我们按照job在server端的提交过程进行分析 JobRequestHandler JobRequestHandler负责处理关于jo...