org.apache.flume.Channel.getName()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(7.4k)|赞(0)|评价(0)|浏览(265)

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

Channel.getName介绍

暂无

代码示例

代码示例来源：origin: apache/flume

  1. @Override
  2.  public String toString() {
  3.   return this.getClass().getName() + "{name:" + name + ", channel:" + channel.getName() + "}";
  4.  }
  5. }

代码示例来源：origin: apache/flume

  1. /**
  2.  *
  3.  * @return A map of name to channel instance.
  4.  */
  5. protected Map<String, Channel> getChannelNameMap() {
  6.  Map<String, Channel> channelNameMap = new HashMap<String, Channel>();
  7.  for (Channel ch : getAllChannels()) {
  8.   channelNameMap.put(ch.getName(), ch);
  9.  }
  10.  return channelNameMap;
  11. }

代码示例来源：origin: apache/flume

  1. private void checkSinkChannelCompatibility(Sink sink, Channel channel)
  2.   throws InstantiationException {
  3.  if (sink instanceof BatchSizeSupported && channel instanceof TransactionCapacitySupported) {
  4.   long transCap = ((TransactionCapacitySupported) channel).getTransactionCapacity();
  5.   long batchSize = ((BatchSizeSupported) sink).getBatchSize();
  6.   if (transCap < batchSize) {
  7.    String msg = String.format(
  8.      "Incompatible sink and channel settings defined. " +
  9.        "sink's batch size is greater than the channels transaction capacity. " +
  10.        "Sink: %s, batch size = %d, channel %s, transaction capacity = %d",
  11.      sink.getName(), batchSize,
  12.      channel.getName(), transCap);
  13.    throw new InstantiationException(msg);
  14.   }
  15.  }
  16. }

代码示例来源：origin: apache/flume

  1. private void checkSourceChannelCompatibility(Source source, Channel channel)
  2.   throws InstantiationException {
  3.  if (source instanceof BatchSizeSupported && channel instanceof TransactionCapacitySupported) {
  4.   long transCap = ((TransactionCapacitySupported) channel).getTransactionCapacity();
  5.   long batchSize = ((BatchSizeSupported) source).getBatchSize();
  6.   if (transCap < batchSize) {
  7.    String msg = String.format(
  8.      "Incompatible source and channel settings defined. " +
  9.        "source's batch size is greater than the channels transaction capacity. " +
  10.        "Source: %s, batch size = %d, channel %s, transaction capacity = %d",
  11.      source.getName(), batchSize,
  12.      channel.getName(), transCap);
  13.    throw new InstantiationException(msg);
  14.   }
  15.  }
  16. }

代码示例来源：origin: apache/flume

  1. && !supervisor.isComponentInErrorState(ch)) {
  2. try {
  3.  logger.info("Waiting for channel: " + ch.getName() +
  4.    " to start. Sleeping for 500 ms");
  5.  Thread.sleep(500);

代码示例来源：origin: apache/flume

  1. for (Channel channel : sourceChannels) {
  2.  ChannelComponent channelComponent =
  3.    Preconditions.checkNotNull(channelComponentMap.get(channel.getName()),
  4.                  String.format("Channel %s", channel.getName()));
  5.  channelComponent.components.add(sourceName);
  6. for (Channel channel : sourceChannels) {
  7.  ChannelComponent channelComponent =
  8.    Preconditions.checkNotNull(channelComponentMap.get(channel.getName()),
  9.                  String.format("Channel %s", channel.getName()));
  10.  channelComponent.components.add(sourceName);

代码示例来源：origin: apache/flume

  1. } else if (t instanceof ChannelException) {
  2.  logger.error("Rpc Sink " + getName() + ": Unable to get event from" +
  3.    " channel " + channel.getName() + ". Exception follows.", t);
  4.  sinkCounter.incrementChannelReadFail();
  5.  status = Status.BACKOFF;

代码示例来源：origin: apache/flume

  1. myChannel.getName() + ". Exception follows.", t);
  2. sinkCounter.incrementEventWriteOrChannelFail(t);
  3. try {

代码示例来源：origin: org.apache.flume/flume-ng-core

  1. @Override
  2.  public String toString() {
  3.   return this.getClass().getName() + "{name:" + name + ", channel:" + channel.getName() + "}";
  4.  }
  5. }

代码示例来源：origin: org.apache.flume/flume-ng-core

  1. /**
  2.  *
  3.  * @return A map of name to channel instance.
  4.  */
  5. protected Map<String, Channel> getChannelNameMap() {
  6.  Map<String, Channel> channelNameMap = new HashMap<String, Channel>();
  7.  for (Channel ch : getAllChannels()) {
  8.   channelNameMap.put(ch.getName(), ch);
  9.  }
  10.  return channelNameMap;
  11. }

代码示例来源：origin: telefonicaid/fiware-cygnus

  1. if (channel.getName().equals(channelName)) {
  2.   break;

代码示例来源：origin: telefonicaid/fiware-cygnus

  1. channelColumns += ",\"" + channel.getName() + "\"";

代码示例来源：origin: org.apache.flume/flume-ng-node

  1. private void checkSinkChannelCompatibility(Sink sink, Channel channel)
  2.   throws InstantiationException {
  3.  if (sink instanceof BatchSizeSupported && channel instanceof TransactionCapacitySupported) {
  4.   long transCap = ((TransactionCapacitySupported) channel).getTransactionCapacity();
  5.   long batchSize = ((BatchSizeSupported) sink).getBatchSize();
  6.   if (transCap < batchSize) {
  7.    String msg = String.format(
  8.      "Incompatible sink and channel settings defined. " +
  9.        "sink's batch size is greater than the channels transaction capacity. " +
  10.        "Sink: %s, batch size = %d, channel %s, transaction capacity = %d",
  11.      sink.getName(), batchSize,
  12.      channel.getName(), transCap);
  13.    throw new InstantiationException(msg);
  14.   }
  15.  }
  16. }

代码示例来源：origin: org.apache.flume/flume-ng-node

  1. private void checkSourceChannelCompatibility(Source source, Channel channel)
  2.   throws InstantiationException {
  3.  if (source instanceof BatchSizeSupported && channel instanceof TransactionCapacitySupported) {
  4.   long transCap = ((TransactionCapacitySupported) channel).getTransactionCapacity();
  5.   long batchSize = ((BatchSizeSupported) source).getBatchSize();
  6.   if (transCap < batchSize) {
  7.    String msg = String.format(
  8.      "Incompatible source and channel settings defined. " +
  9.        "source's batch size is greater than the channels transaction capacity. " +
  10.        "Source: %s, batch size = %d, channel %s, transaction capacity = %d",
  11.      source.getName(), batchSize,
  12.      channel.getName(), transCap);
  13.    throw new InstantiationException(msg);
  14.   }
  15.  }
  16. }

代码示例来源：origin: jaibeermalik/searchanalytics-bigdata

  1. selectorProperties.put("mapping.VIEWED", HDFSChannel.getName() + " "
  2.     + ESChannel.getName() + " " + sparkAvroChannel.getName() + " "
  3.     + HbaseChannel.getName());
  4. selectorProperties.put("mapping.FAVOURITE", HDFSChannel.getName() + " "
  5.     + ESChannel.getName() + " " + sparkAvroChannel.getName() + " "
  6.     + HbaseChannel.getName());
  7. selectorProperties.put("default", HDFSChannel.getName() + " "
  8.     + sparkAvroChannel.getName() + " " + HbaseChannel.getName());
  9. Context selectorContext = new Context(selectorProperties);
  10. selector.configure(selectorContext);

代码示例来源：origin: org.apache.flume/flume-ng-node

  1. && !supervisor.isComponentInErrorState(ch)) {
  2. try {
  3.  logger.info("Waiting for channel: " + ch.getName() +
  4.    " to start. Sleeping for 500 ms");
  5.  Thread.sleep(500);

代码示例来源：origin: org.apache.flume/flume-ng-node

  1. for (Channel channel : sourceChannels) {
  2.  ChannelComponent channelComponent =
  3.    Preconditions.checkNotNull(channelComponentMap.get(channel.getName()),
  4.                  String.format("Channel %s", channel.getName()));
  5.  channelComponent.components.add(sourceName);
  6. for (Channel channel : sourceChannels) {
  7.  ChannelComponent channelComponent =
  8.    Preconditions.checkNotNull(channelComponentMap.get(channel.getName()),
  9.                  String.format("Channel %s", channel.getName()));
  10.  channelComponent.components.add(sourceName);

代码示例来源：origin: telefonicaid/fiware-cygnus

  1. jsonStr += "{\"name\":\"" + channel.getName() + "\","
  2.     + "\"status\":\"" + channel.getLifecycleState().toString() + "\",";

代码示例来源：origin: org.apache.flume/flume-ng-core

  1. } else if (t instanceof ChannelException) {
  2.  logger.error("Rpc Sink " + getName() + ": Unable to get event from" +
  3.    " channel " + channel.getName() + ". Exception follows.", t);
  4.  sinkCounter.incrementChannelReadFail();
  5.  status = Status.BACKOFF;

代码示例来源：origin: org.apache.flume.flume-ng-sinks/flume-ng-morphline-solr-sink

  1. myChannel.getName() + ". Exception follows.", t);
  2. sinkCounter.incrementEventWriteOrChannelFail(t);
  3. try {

内容来源于网络，如有侵权，请联系作者删除！

Channel

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com