本文整理汇总了Java中org.apache.flume.Source类的典型用法代码示例。如果您正苦于以下问题:Java Source类的具体用法?Java Source怎么用?Java Source使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Source类属于org.apache.flume包,在下文中一共展示了Source类的11个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: stop
import org.apache.flume.Source; //导入依赖的package包/类
@Override
public void stop() {
runner.shouldStop.set(true);
try {
runnerThread.interrupt();
runnerThread.join();
} catch (InterruptedException e) {
logger.warn("Interrupted while waiting for polling runner to stop. Please report this.", e);
Thread.currentThread().interrupt();
}
Source source = getSource();
source.stop();
ChannelProcessor cp = source.getChannelProcessor();
cp.close();
lifecycleState = LifecycleState.STOP;
}
开发者ID:moueimei,项目名称:flume-release-1.7.0,代码行数:21,代码来源:PollableSourceRunner.java
示例2: testDuplicateCreate
import org.apache.flume.Source; //导入依赖的package包/类
@Test
public void testDuplicateCreate() {
Source avroSource1 = sourceFactory.create("avroSource1", "avro");
Source avroSource2 = sourceFactory.create("avroSource2", "avro");
Assert.assertNotNull(avroSource1);
Assert.assertNotNull(avroSource2);
Assert.assertNotSame(avroSource1, avroSource2);
Assert.assertTrue(avroSource1 instanceof AvroSource);
Assert.assertTrue(avroSource2 instanceof AvroSource);
Source s1 = sourceFactory.create("avroSource1", "avro");
Source s2 = sourceFactory.create("avroSource2", "avro");
Assert.assertNotSame(avroSource1, s1);
Assert.assertNotSame(avroSource2, s2);
}
开发者ID:moueimei,项目名称:flume-release-1.7.0,代码行数:20,代码来源:TestDefaultSourceFactory.java
示例3: start
import org.apache.flume.Source; //导入依赖的package包/类
/**
* Started the agent. Can only be called after a successful call to
* configure().
*
* @throws FlumeException if a component cannot be started
* @throws IllegalStateException if the agent has not been configured or is
* already started
*/
public void start()
throws FlumeException {
if (state == State.STARTED) {
throw new IllegalStateException("Cannot be started while started");
} else if (state == State.NEW) {
throw new IllegalStateException("Cannot be started before being " +
"configured");
}
// This check needs to be done before doStart(),
// as doStart() accesses sourceRunner.getSource()
Source source = Preconditions.checkNotNull(sourceRunner.getSource(),
"Source runner returned null source");
if (source instanceof EmbeddedSource) {
embeddedSource = (EmbeddedSource)source;
} else {
throw new IllegalStateException("Unknown source type: " + source.getClass().getName());
}
doStart();
state = State.STARTED;
}
开发者ID:moueimei,项目名称:flume-release-1.7.0,代码行数:29,代码来源:EmbeddedAgent.java
示例4: create
import org.apache.flume.Source; //导入依赖的package包/类
@Override
public Source create(String name, String type) throws FlumeException {
Preconditions.checkNotNull(name, "name");
Preconditions.checkNotNull(type, "type");
logger.info("Creating instance of source {}, type {}", name, type);
Class<? extends Source> sourceClass = getClass(type);
try {
Source source = sourceClass.newInstance();
source.setName(name);
return source;
} catch (Exception ex) {
throw new FlumeException("Unable to create source: " + name
+ ", type: " + type + ", class: " + sourceClass.getName(), ex);
}
}
开发者ID:moueimei,项目名称:flume-release-1.7.0,代码行数:16,代码来源:DefaultSourceFactory.java
示例5: start
import org.apache.flume.Source; //导入依赖的package包/类
@Override
public void start() {
Source source = getSource();
ChannelProcessor cp = source.getChannelProcessor();
cp.initialize();
source.start();
lifecycleState = LifecycleState.START;
}
开发者ID:moueimei,项目名称:flume-release-1.7.0,代码行数:9,代码来源:EventDrivenSourceRunner.java
示例6: stop
import org.apache.flume.Source; //导入依赖的package包/类
@Override
public void stop() {
Source source = getSource();
source.stop();
ChannelProcessor cp = source.getChannelProcessor();
cp.close();
lifecycleState = LifecycleState.STOP;
}
开发者ID:moueimei,项目名称:flume-release-1.7.0,代码行数:9,代码来源:EventDrivenSourceRunner.java
示例7: verifySourceCreation
import org.apache.flume.Source; //导入依赖的package包/类
private void verifySourceCreation(String name, String type,
Class<?> typeClass) throws Exception {
Source src = sourceFactory.create(name, type);
Assert.assertNotNull(src);
Assert.assertTrue(typeClass.isInstance(src));
}
开发者ID:moueimei,项目名称:flume-release-1.7.0,代码行数:7,代码来源:TestDefaultSourceFactory.java
示例8: verifySourceCreation
import org.apache.flume.Source; //导入依赖的package包/类
private void verifySourceCreation(String name, String type,
Class<?> typeClass) throws FlumeException {
Source src = sourceFactory.create(name, type);
Assert.assertNotNull(src);
Assert.assertTrue(typeClass.isInstance(src));
}
开发者ID:moueimei,项目名称:flume-release-1.7.0,代码行数:7,代码来源:TestJMSSourceCreation.java
示例9: cleanUp
import org.apache.flume.Source; //导入依赖的package包/类
@After
public void cleanUp() {
for (Source source : sources) {
source.stop();
}
}
开发者ID:moueimei,项目名称:flume-release-1.7.0,代码行数:7,代码来源:TestLoadBalancingLog4jAppender.java
示例10: PeriodicHandler
import org.apache.flume.Source; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public PeriodicHandler(Source source, int emitFreqMS, Class<?> interceptorClass) {
this.source = source;
this.emitFreqMS = emitFreqMS;
this.interceptorClass = (Class<? extends AnalyticInterceptor>) interceptorClass;
}
开发者ID:jrkinley,项目名称:flume-interceptor-analytics,代码行数:7,代码来源:PeriodicEmissionSource.java
示例11: verifySourceCreation
import org.apache.flume.Source; //导入依赖的package包/类
private void verifySourceCreation(String name, String type, Class<?> typeClass) throws FlumeException {
SourceFactory sourceFactory = new DefaultSourceFactory();
Source source = sourceFactory.create(name, type);
Assert.assertNotNull(source);
Assert.assertTrue(typeClass.isInstance(source));
}
开发者ID:DevOps-TangoMe,项目名称:flume-redis,代码行数:7,代码来源:TestRedisSourceCreation.java
注:本文中的org.apache.flume.Source类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论