本文整理了Java中org.apache.flume.Channel.getLifecycleState()
方法的一些代码示例,展示了Channel.getLifecycleState()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Channel.getLifecycleState()
方法的具体详情如下:
包路径:org.apache.flume.Channel
类名称: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() + "\",";
内容来源于网络,如有侵权,请联系作者删除!