azkaban.utils.Props.getSource()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(105)

本文整理了Java中azkaban.utils.Props.getSource()方法的一些代码示例,展示了Props.getSource()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Props.getSource()方法的具体详情如下:
包路径:azkaban.utils.Props
类名称:Props
方法名:getSource

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);
  }
}

相关文章