com.ucar.datalink.domain.media.parameter.zk.ZkMediaSrcParameter.getServers()方法的使用及代码示例-6ren

gpt4 book

didi

com.ucar.datalink.domain.media.parameter.zk.ZkMediaSrcParameter.getServers()方法的使用及代码示例

转载作者：知者更新时间：2024-03-14 12:59:31

31

4

gpt4 key购买

nike

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

ZkMediaSrcParameter.getServers介绍

暂无

代码示例

代码示例来源：origin: ucarGroup/DataLink

@Override
public String toString() {
  return "zkAddress:"+zkParameter.getServers()+"    znode:"+hbaseParameter.getZnodeParent();
}

代码示例来源：origin: ucarGroup/DataLink

@Override
public String toString() {
  return "zkAddress:"+zkParameter.getServers()+"    znode:"+hbaseParameter.getZnodeParent() + "    table name:"+tableName;
}

代码示例来源：origin: ucarGroup/DataLink

@Override
public String toString() {
  return "zkAddress:"+zkParameter.getServers()+"    znode:"+hbaseParameter.getZnodeParent() + "    table name:"+tableName;
}

代码示例来源：origin: ucarGroup/DataLink

@Override
public String toString() {
  return "zkAddress:"+zkParameter.getServers()+"    znode:"+hbaseParameter.getZnodeParent() + "    table name:"+tableName;
}

代码示例来源：origin: ucarGroup/DataLink

@Override
public String toString() {
  return "zkAddress:"+zkParameter.getServers()+"    znode:"+hbaseParameter.getZnodeParent();
}

代码示例来源：origin: ucarGroup/DataLink

private List<MediaSourceInfo> buildZkMediaSources() {
  List<MediaSourceInfo> list = mediaService.getMediaSourcesByTypes(MediaSourceType.ZOOKEEPER);
  return list == null ?
      Lists.newArrayList() :
      list.stream().
          filter(i -> ((ZkMediaSrcParameter) i.getParameterObj()).getServers().equals(ManagerConfig.current().getZkServer()))
          .collect(Collectors.toList());
}

代码示例来源：origin: ucarGroup/DataLink

private void checkZkServers(ZkMediaSourceView zkMediaSourceView) throws IOException {
  String servers = zkMediaSourceView.getZkMediaSrcParameter().getServers();
  String[] serversArray = servers.split(",");
  List<String> serversList = new ArrayList<String>();
  for (String str : serversArray) {
    serversList.add(str);
  }
  for (String server : serversList) {
    String[] array = server.split(":");
    if (array.length > 1) {
      String host = array[0];
      int port = Integer.valueOf(array[1]);
      try {
        String result = send4LetterWord(host, port, "ruok", 5000);
        if (result.equals("imok\n")) {
          continue;
        }
      } catch (IOException e) {
        throw new IOException("Zk服务器验证失败.", e);
      }
    }else {
      throw new ValidationException("ip地址格式不正确.");
    }
  }
}

代码示例来源：origin: ucarGroup/DataLink

private void checkZkInfo(MediaSourceInfo mediaSourceInfo) {
  String msName = mediaSourceInfo.getName();
  String namePrefix = "zk_";
  if (!msName.startsWith(namePrefix)) {
    throw new ValidationException(String.format("zk数据源名称必须以%s为前缀.", namePrefix));
  }
  Set<MediaSourceType> setMediaSource = new HashSet<MediaSourceType>();
  setMediaSource.add(MediaSourceType.ZOOKEEPER);
  List<MediaSourceInfo> zkList = getListByType(setMediaSource);
  if (zkList != null) {
    zkList.forEach(zk -> {
      String servers = ((ZkMediaSrcParameter) zk.getParameterObj()).getServers();
      if (servers.equals(((ZkMediaSrcParameter) mediaSourceInfo.getParameterObj()).getServers()) && !zk.getId().equals(mediaSourceInfo.getId())) {
        throw new ValidationException(String.format("ip地址已经存在：%s.", servers));
      }
    });
  }
}

代码示例来源：origin: ucarGroup/DataLink

private void setHdfsParameter(MediaSourceInfo mediaSourceInfo) {
  HDFSMediaSrcParameter hdfsMediaSrcParameter = mediaSourceInfo.getParameterObj();
  this.hdfsAddress = hdfsMediaSrcParameter.getNameServices();
  this.hdfsUri = URI.create(this.hdfsAddress);
  this.hadoopUser = hdfsMediaSrcParameter.getHadoopUser();
  this.haNameNode1 = hdfsMediaSrcParameter.getNameNode1();
  this.haNameNode2 = hdfsMediaSrcParameter.getNameNode2();
  MediaSourceInfo zkMediaSrcInfo = DataLinkFactory.getObject(MediaSourceService.class).getById(hdfsMediaSrcParameter.getZkMediaSourceId());
  String zkServers = ((ZkMediaSrcParameter) zkMediaSrcInfo.getParameterObj()).getServers();
  String[] zkArray = zkServers.split(",");
  List<String> zkList = new ArrayList<>();
  Collections.addAll(zkList, zkArray);
  List<String> ipList = new ArrayList<>();
  for (String zk : zkList) {
    String[] zkServer = zk.split(":");
    ipList.add(zkServer[0]);
    this.zkPort = zkServer[1];
  }
  this.zkUrl = String.join(",", ipList);
}

代码示例来源：origin: ucarGroup/DataLink

public static List<HBaseRange> generateHBaseSplitInfo(MediaSourceInfo info, String tableName, int splitCount) {
  checkHbase(info);
  HBaseMediaSrcParameter parameter = info.getParameterObj();
  long zkId = parameter.getZkMediaSourceId();
  String znode = parameter.getZnodeParent();
  MediaSourceInfo zkInfo = dao.findMediaSourceById(zkId);
  checkZookeepr(zkInfo);
  ZkMediaSrcParameter zkParameter = zkInfo.getParameterObj();
  HBaseParameterVO vo = new HBaseParameterVO();
  vo.setTableName(tableName);
  vo.setZkAddress(zkParameter.getServers());
  vo.setPort(zkParameter.parsePort()+"");
  vo.setZnode(parameter.getZnodeParent());
  vo.setSplitCount(splitCount);
  String json = execute(vo,GENERATE_SPLIT_INFO);
  Map<String,Object> map = JSONObject.parseObject(json,Map.class);
  JSONArray array = (JSONArray)map.get("range");
  Object[] obj_arr = array.toArray();
  List<HBaseRange> list = new ArrayList<>();
  for(Object o : obj_arr) {
    String str = JSONObject.toJSONString(o);
    HBaseRange hr = JSONObject.parseObject(str, HBaseRange.class);
    list.add(hr);
  }
  return list;
}

代码示例来源：origin: ucarGroup/DataLink

@RequestMapping(value = "/initZk")
@ResponseBody
public Page<ZkMediaSourceView> initZk() {
  Set<MediaSourceType> setMediaSource = new HashSet<MediaSourceType>();
  setMediaSource.add(MediaSourceType.ZOOKEEPER);
  List<MediaSourceInfo> zkMediaSourceList = mediaSourceService.getListByType(setMediaSource);
  List<ZkMediaSourceView> taskView = zkMediaSourceList.stream().map(i -> {
    ZkMediaSourceView view = new ZkMediaSourceView();
    view.setId(i.getId());
    view.setName(i.getName());
    view.setDesc(i.getDesc());
    view.setCreateTime(i.getCreateTime());
    view.getZkMediaSrcParameter().setMediaSourceType(i.getType());
    view.getZkMediaSrcParameter().setServers(((ZkMediaSrcParameter) i.getParameterObj()).getServers());
    view.getZkMediaSrcParameter().setSessionTimeout(((ZkMediaSrcParameter) i.getParameterObj()).getSessionTimeout());
    view.getZkMediaSrcParameter().setConnectionTimeout(((ZkMediaSrcParameter) i.getParameterObj()).getConnectionTimeout());
    return view;
  }).collect(Collectors.toList());
  return new Page<ZkMediaSourceView>(taskView);
}

代码示例来源：origin: ucarGroup/DataLink

public static int getRegionCount(MediaSourceInfo info, String tableName) {
  checkHbase(info);
  HBaseMediaSrcParameter parameter = info.getParameterObj();
  long zkId = parameter.getZkMediaSourceId();
  String znode = parameter.getZnodeParent();
  MediaSourceInfo zkInfo = dao.findMediaSourceById(zkId);
  checkZookeepr(zkInfo);
  ZkMediaSrcParameter zkParameter = zkInfo.getParameterObj();
  HBaseParameterVO vo = new HBaseParameterVO();
  vo.setTableName(tableName);
  vo.setZkAddress(zkParameter.getServers());
  vo.setPort(zkParameter.parsePort()+"");
  vo.setZnode(parameter.getZnodeParent());
  String json = execute(vo,GET_REGION_COUNT);
  int result = -1;
  try {
    result = Integer.parseInt(json);
  } catch(Exception e) {
    logger.error(e.getMessage(),e);
  }
  return result;
}

代码示例来源：origin: ucarGroup/DataLink

private ReplicationConfig buidReplicationConfig(HBaseReaderParameter readerParameter) {
    ReplicationConfig config = new ReplicationConfig();
    config.setHbaseName("hbase-4-datalink");
    config.setZnodeParent(readerParameter.getReplZnodeParent());
    ZkMediaSrcParameter zkMediaSrcParameter = DataLinkFactory.getObject(MediaSourceService.class).
        getById(readerParameter.getReplZkMediaSourceId()).getParameterObj();
    config.setZkConfig(new ZkConfig(zkMediaSrcParameter.getServers(), 6000, 60000));
    return config;
  }
}

代码示例来源：origin: ucarGroup/DataLink

/**
 * 根据传入的MediaSourceInfo 获取所有表的元信息
 * @param info
 * @return
 */
public static List<MediaMeta> getTables(MediaSourceInfo info) {
  checkHbase(info);
  HBaseMediaSrcParameter parameter = info.getParameterObj();
  long zkId = parameter.getZkMediaSourceId();
  String znode = parameter.getZnodeParent();
  MediaSourceInfo zkInfo = dao.findMediaSourceById(zkId);
  checkZookeepr(zkInfo);
  ZkMediaSrcParameter zkParameter = zkInfo.getParameterObj();
  HBaseParameterVO vo = new HBaseParameterVO();
  vo.setTableName("");
  vo.setZkAddress(zkParameter.getServers());
  vo.setPort(zkParameter.parsePort()+"");
  vo.setZnode(parameter.getZnodeParent());
  String json = execute(vo,GET_TABLES_URL);
  return JSONObject.parseArray(json, MediaMeta.class);
}

代码示例来源：origin: ucarGroup/DataLink

/**
 * 根据传入的MediaSourceInfo和表名，获取这个表下的所有列的元信息
 * @param info
 * @param tableName
 * @return
 */
public static List<ColumnMeta> getColumns(MediaSourceInfo info, String tableName) {
  checkHbase(info);
  HBaseMediaSrcParameter parameter = info.getParameterObj();
  long zkId = parameter.getZkMediaSourceId();
  String znode = parameter.getZnodeParent();
  MediaSourceInfo zkInfo = dao.findMediaSourceById(zkId);
  checkZookeepr(zkInfo);
  ZkMediaSrcParameter zkParameter = zkInfo.getParameterObj();
  HBaseParameterVO vo = new HBaseParameterVO();
  vo.setTableName(tableName);
  vo.setZkAddress(zkParameter.getServers());
  vo.setPort(zkParameter.parsePort()+"");
  vo.setZnode(parameter.getZnodeParent());
  String json = execute(vo,GET_COLUMNS_URL);
  return JSONObject.parseArray(json, ColumnMeta.class);
}

31

4

0

文章推荐： pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperPaths.maxRateLeaderPath()方法的使用及代码示例

文章推荐： pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperPaths.topicsBlacklistPath()方法的使用及代码示例

文章推荐： pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperPaths.consumersMaxRatePath()方法的使用及代码示例

文章推荐： pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperPaths.consumersRateHistoryPath()方法的使用及代码示例

Ruby 方法() 方法
我想了解 Ruby 方法 methods() 是如何工作的。我尝试使用“ruby 方法”在 Google 上搜索，但这不是我需要的。我也看过 ruby-doc.org，但我没有找到这种方法。
VBS教程：方法-Test 方法
Test 方法对指定的字符串执行一个正则表达式搜索，并返回一个 Boolean 值指示是否找到匹配的模式。 object.Test(string) 参数 object 必选项。总是一个
VBS教程：方法-Replace 方法
Replace 方法替换在正则表达式查找中找到的文本。 object.Replace(string1, string2) 参数 object 必选项。总是一个 RegExp 对象的名称。
VBS教程：方法-Raise 方法
Raise 方法生成运行时错误 object.Raise(number, source, description, helpfile, helpcontext) 参数 object 应为
VBS教程：方法-Execute 方法
Execute 方法对指定的字符串执行正则表达式搜索。 object.Execute(string) 参数 object 必选项。总是一个 RegExp 对象的名称。 string
VBS教程：方法-Clear 方法
Clear 方法清除 Err 对象的所有属性设置。 object.Clear object 应为 Err 对象的名称。说明在错误处理后，使用 Clear 显式地清除 Err 对象。此
VBS教程：方法-CopyFile 方法
CopyFile 方法将一个或多个文件从某位置复制到另一位置。 object.CopyFile source, destination[, overwrite] 参数 object 必选
VBS教程：方法-Copy 方法
Copy 方法将指定的文件或文件夹从某位置复制到另一位置。 object.Copy destination[, overwrite] 参数 object 必选项。应为 File 或 F
VBS教程：方法-Close 方法
Close 方法关闭打开的 TextStream 文件。 object.Close object 应为 TextStream 对象的名称。说明下面例子举例说明如何使用 Close 方
VBS教程：方法-BuildPath 方法
BuildPath 方法向现有路径后添加名称。 object.BuildPath(path, name) 参数 object 必选项。应为 FileSystemObject 对象的名称
VBS教程：方法-GetFolder 方法
GetFolder 方法返回与指定的路径中某文件夹相应的 Folder 对象。 object.GetFolder(folderspec) 参数 object 必选项。应为 FileSy
VBS教程：方法-GetFileName 方法
GetFileName 方法返回指定路径（不是指定驱动器路径部分）的最后一个文件或文件夹。 object.GetFileName(pathspec) 参数 object 必选项。应为
VBS教程：方法-GetFile 方法
GetFile 方法返回与指定路径中某文件相应的 File 对象。 object.GetFile(filespec) 参数 object 必选项。应为 FileSystemObject
VBS教程：方法-GetExtensionName 方法
GetExtensionName 方法返回字符串，该字符串包含路径最后一个组成部分的扩展名。 object.GetExtensionName(path) 参数 object 必选项。应
VBS教程：方法-GetDriveName 方法
GetDriveName 方法返回包含指定路径中驱动器名的字符串。 object.GetDriveName(path) 参数 object 必选项。应为 FileSystemObjec
VBS教程：方法-GetDrive 方法
GetDrive 方法返回与指定的路径中驱动器相对应的 Drive 对象。 object.GetDrive drivespec 参数 object 必选项。应为 FileSystemO
VBS教程：方法-GetBaseName 方法
GetBaseName 方法返回字符串，其中包含文件的基本名 (不带扩展名), 或者提供的路径说明中的文件夹。 object.GetBaseName(path) 参数 object 必
VBS教程：方法-GetAbsolutePathName 方法
GetAbsolutePathName 方法从提供的指定路径中返回完整且含义明确的路径。 object.GetAbsolutePathName(pathspec) 参数 object
VBS教程：方法-FolderExists 方法
FolderExists 方法如果指定的文件夹存在，则返回 True；否则返回 False。 object.FolderExists(folderspec) 参数 object 必选项
VBS教程：方法-FileExists 方法
FileExists 方法如果指定的文件存在返回 True；否则返回 False。 object.FileExists(filespec) 参数 object 必选项。应为 FileS

知者

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

滴滴打车优惠券

全站热门文章

Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com