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

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

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

Channel.getLifecycleState介绍

暂无

代码示例

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

while (ch.getLifecycleState() != LifecycleState.START
  && !supervisor.isComponentInErrorState(ch)) {
 try {

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

/**
 * Stops the channels.
 */
private void stopChannels() {
  for (String channelName : channelsRef.keySet()) {
    Channel channel = channelsRef.get(channelName);
    LifecycleState state = channel.getLifecycleState();
    System.out.println("Stopping " + channelName + " (lyfecycle state=" + state.toString() + ")");
    supervisorRef.unsupervise(channel);
  } // for
} // stopChannels

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

while (ch.getLifecycleState() != LifecycleState.START
  && !supervisor.isComponentInErrorState(ch)) {
 try {

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

+ "\"status\":\"" + channel.getLifecycleState().toString() + "\",";

相关文章