本文整理了Java中azkaban.utils.Props.getSource()
方法的一些代码示例,展示了Props.getSource()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Props.getSource()
方法的具体详情如下:
包路径:azkaban.utils.Props
类名称:Props
方法名:getSource
[英]Gets source.
[中]获取来源。
代码示例来源:origin: azkaban/azkaban
public void setProps(final Props props) {
this.props = props;
this.parentSource =
props.getParent() == null ? null : props.getParent().getSource();
this.propSource = props.getSource();
}
代码示例来源:origin: azkaban/azkaban
public JobSummaryServlet(final Props props) {
this.props = props;
this.viewerName = props.getString("viewer.name");
this.viewerPath = props.getString("viewer.path");
this.webResourcesPath =
new File(new File(props.getSource()).getParentFile().getParentFile(),
"web");
this.webResourcesPath.mkdirs();
setResourceDirectory(this.webResourcesPath);
}
代码示例来源:origin: azkaban/azkaban
@Override
public void uploadProjectProperty(final Project project, final Props props)
throws ProjectManagerException {
try {
uploadProjectProperty(project, props.getSource(), props);
} catch (final IOException e) {
throw new ProjectManagerException("Error uploading project property file", e);
}
}
代码示例来源:origin: azkaban/azkaban
@Override
public void updateProjectProperty(final Project project, final Props props)
throws ProjectManagerException {
try {
updateProjectProperty(project, props.getSource(), props);
} catch (final IOException e) {
throw new ProjectManagerException("Error uploading project property file", e);
}
}
代码示例来源:origin: azkaban/azkaban
public static Map<String, Object> toHierarchicalMap(final Props props) {
final Map<String, Object> propsMap = new HashMap<>();
propsMap.put("source", props.getSource());
propsMap.put("props", toStringMap(props, true));
if (props.getParent() != null) {
propsMap.put("parent", toHierarchicalMap(props.getParent()));
}
return propsMap;
}
代码示例来源:origin: azkaban/azkaban
@Override
public void uploadProjectProperties(final Project project, final List<Props> properties)
throws ProjectManagerException {
for (final Props props : properties) {
try {
uploadProjectProperty(project, props.getSource(), props);
} catch (final IOException e) {
throw new ProjectManagerException("Error uploading project property file", e);
}
}
}
代码示例来源:origin: azkaban/azkaban
node.setPropsSource(parent.getSource());
代码示例来源:origin: azkaban/azkaban
oldProps = this.projectLoader.fetchProjectProperty(project, prop.getSource());
代码示例来源:origin: azkaban/azkaban
@Test
public void testUploadOrUpdateProjectProperty() throws Exception {
final Props props = new Props();
props.setSource("source1");
props.put("key1", "value1");
props.put("key2", "value2");
createThreeProjects();
final Project project = this.loader.fetchProjectByName("mytestProject");
this.loader.uploadProjectProperty(project, props);
final Props sameProps = this.loader.fetchProjectProperty(project, props.getSource());
Assert.assertEquals(sameProps.get("key1"), "value1");
Assert.assertEquals(sameProps.get("key2"), "value2");
props.put("key2", "value9");
this.loader.updateProjectProperty(project, props);
final Props sameProps2 = this.loader.fetchProjectProperty(project, props.getSource());
Assert.assertEquals(sameProps2.get("key2"), "value9");
}
代码示例来源:origin: com.linkedin.azkaban/azkaban
public void setProps(Props props) {
this.props = props;
this.parentSource = props.getParent() == null ? null : props.getParent().getSource();
this.propSource = props.getSource();
}
代码示例来源:origin: com.linkedin.azkaban/azkaban-common
public void setProps(final Props props) {
this.props = props;
this.parentSource =
props.getParent() == null ? null : props.getParent().getSource();
this.propSource = props.getSource();
}
代码示例来源:origin: com.linkedin.azkaban/azkaban
public static Map<String,Object> toHierarchicalMap(Props props) {
Map<String,Object> propsMap = new HashMap<String,Object>();
propsMap.put("source", props.getSource());
propsMap.put("props", toStringMap(props, true));
if (props.getParent() != null) {
propsMap.put("parent", toHierarchicalMap(props.getParent()));
}
return propsMap;
}
}
代码示例来源:origin: com.linkedin.azkaban/azkaban-common
@Override
public void uploadProjectProperty(final Project project, final Props props)
throws ProjectManagerException {
try {
uploadProjectProperty(project, props.getSource(), props);
} catch (final IOException e) {
throw new ProjectManagerException("Error uploading project property file", e);
}
}
代码示例来源:origin: com.linkedin.azkaban/azkaban-common
@Override
public void uploadProjectProperties(final Project project, final List<Props> properties)
throws ProjectManagerException {
for (final Props props : properties) {
try {
uploadProjectProperty(project, props.getSource(), props);
} catch (final IOException e) {
throw new ProjectManagerException("Error uploading project property file", e);
}
}
}
代码示例来源:origin: com.linkedin.azkaban/azkaban-common
@Override
public void updateProjectProperty(final Project project, final Props props)
throws ProjectManagerException {
try {
updateProjectProperty(project, props.getSource(), props);
} catch (final IOException e) {
throw new ProjectManagerException("Error uploading project property file", e);
}
}
代码示例来源:origin: com.linkedin.azkaban/az-core
/**
* To hierarchical map map.
*
* @param props the props
* @return the map
*/
public static Map<String, Object> toHierarchicalMap(final Props props) {
final Map<String, Object> propsMap = new HashMap<>();
propsMap.put("source", props.getSource());
propsMap.put("props", toStringMap(props, true));
if (props.getParent() != null) {
propsMap.put("parent", toHierarchicalMap(props.getParent()));
}
return propsMap;
}
代码示例来源:origin: com.linkedin.azkaban/azkaban
public void setJobOverrideProperty(Project project, Props prop, String jobName) throws ProjectManagerException {
prop.setSource(jobName+".jor");
Props oldProps = projectLoader.fetchProjectProperty(project, prop.getSource());
if(oldProps == null) {
projectLoader.uploadProjectProperty(project, prop);
}
else {
projectLoader.updateProjectProperty(project, prop);
}
return;
}
代码示例来源:origin: com.linkedin.azkaban/azkaban
@Override
public void updateProjectProperty(Project project, Props props) throws ProjectManagerException {
Connection connection = getConnection();
try {
updateProjectProperty(connection, project, props.getSource(), props);
connection.commit();
}
catch (SQLException e) {
throw new ProjectManagerException("Error uploading project property files", e);
}
catch (IOException e) {
throw new ProjectManagerException("Error uploading project property file", e);
}
finally {
DbUtils.closeQuietly(connection);
}
}
代码示例来源:origin: com.linkedin.azkaban/azkaban
@Override
public void uploadProjectProperties(Project project, List<Props> properties) throws ProjectManagerException {
Connection connection = getConnection();
try {
for (Props props: properties) {
uploadProjectProperty(connection, project, props.getSource(), props);
}
connection.commit();
}
catch (SQLException e) {
throw new ProjectManagerException("Error uploading project property files", e);
}
catch (IOException e) {
throw new ProjectManagerException("Error uploading project property files", e);
}
finally {
DbUtils.closeQuietly(connection);
}
}
代码示例来源:origin: com.linkedin.azkaban/azkaban
@Override
public void uploadProjectProperty(Project project, Props props) throws ProjectManagerException {
Connection connection = getConnection();
try {
uploadProjectProperty(connection, project, props.getSource(), props);
connection.commit();
}
catch (SQLException e) {
throw new ProjectManagerException("Error uploading project property files", e);
}
catch (IOException e) {
throw new ProjectManagerException("Error uploading project property file", e);
}
finally {
DbUtils.closeQuietly(connection);
}
}
内容来源于网络,如有侵权,请联系作者删除!