Examples of org.apache.flume.channel.ChannelProcessor

org.apache.flume.channel.ChannelProcessor
A channel processor exposes operations to put {@link Event}s into {@link Channel}s. These operations will propagate a {@link ChannelException}if any errors occur while attempting to write to {@code required} channels.Each channel processor instance is configured with a {@link ChannelSelector}instance that specifies which channels are {@linkplain ChannelSelector#getRequiredChannels(Event) required} and whichchannels are {@linkplain ChannelSelector#getOptionalChannels(Event) optional}.

    channels.add(channel);


    ChannelSelector rcs = new ReplicatingChannelSelector();
    rcs.setChannels(channels);


    source.setChannelProcessor(new ChannelProcessor(rcs));
    Context context = new Context();
    context.put("port", String.valueOf(TEST_SYSLOG_PORT));
    context.put("keepFields", keepFields);


    source.configure(context);

View Full Code Here

    SinkRunner sinkRunner = new SinkRunner(proc);
    sinkRunner.start();


    ChannelSelector rcs = new ReplicatingChannelSelector();
    rcs.setChannels(Collections.singletonList(channel));
    ChannelProcessor chp = new ChannelProcessor(rcs);
    source.setChannelProcessor(chp);
    source.start();


    Thread.sleep(5000);
    source.stop();

View Full Code Here


  }


  ChannelProcessor createGoodChannel() {


    ChannelProcessor channelProcessor = mock(ChannelProcessor.class);


    events = Lists.newArrayList();


    doAnswer(new Answer<Void>() {
      @Override

View Full Code Here

    return channelProcessor;


  }


  ChannelProcessor createBadChannel() {
    ChannelProcessor channelProcessor = mock(ChannelProcessor.class);


    doAnswer(new Answer<Void>() {
      @Override
      public Void answer(InvocationOnMock invocation) throws Throwable {
        throw new ChannelException("channel intentional broken");

View Full Code Here

    channels.add(channel);


    ChannelSelector rcs = new ReplicatingChannelSelector();
    rcs.setChannels(channels);


    source.setChannelProcessor(new ChannelProcessor(rcs));
    tmpDir = Files.createTempDir();
  }

View Full Code Here

    sink.start();
    
    source = new EmbeddedSource(sink);    
    ChannelSelector rcs = new ReplicatingChannelSelector();
    rcs.setChannels(Collections.singletonList(channel));
    ChannelProcessor chp = new ChannelProcessor(rcs);
    Context chpContext = new Context();
    chpContext.put("interceptors", "uuidinterceptor");
    chpContext.put("interceptors.uuidinterceptor.type", UUIDInterceptor.Builder.class.getName());
    chp.configure(chpContext);
    source.setChannelProcessor(chp);
    
    deleteAllDocuments();
  }

View Full Code Here

    channels.add(sourceChannel);


    ChannelSelector rcs = new ReplicatingChannelSelector();
    rcs.setChannels(channels);


    source.setChannelProcessor(new ChannelProcessor(rcs));


    Context context = new Context();
    context.put("port", port.toString());
    context.put("bind", hostname);
    context.put("threads", "50");

View Full Code Here

    channels.add(sourceChannel);


    ChannelSelector rcs = new ReplicatingChannelSelector();
    rcs.setChannels(channels);


    source.setChannelProcessor(new ChannelProcessor(rcs));


    Context context = new Context();
    context.put("port", port.toString());
    context.put("bind", hostname);
    context.put("threads", "50");

View Full Code Here

    channels.add(channel);


    ChannelSelector rcs = new ReplicatingChannelSelector();
    rcs.setChannels(channels);


    source.setChannelProcessor(new ChannelProcessor(rcs));


    channel.start();


    httpsSource.setChannelProcessor(new ChannelProcessor(rcs));


    // HTTP context
    Context context = new Context();


    context.put("port", String.valueOf(selectedPort));

View Full Code Here

    channels.add(channel);


    ChannelSelector rcs = new ReplicatingChannelSelector();
    rcs.setChannels(channels);


    source.setChannelProcessor(new ChannelProcessor(rcs));
    Context context = new Context();
    StringBuilder ports = new StringBuilder();
    for (int i = 0; i < 1000; i++) {
      ports.append(String.valueOf(BASE_TEST_SYSLOG_PORT + i)).append(" ");
    }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.apache.flume.channel.ChannelProcessor

org.apache.flink.streaming.connectors.flume.FlumeSource

org.apache.flume.channel.file.CountingSourceRunner

org.apache.flume.clients.log4jappender.TestLoadBalancingLog4jAppender

org.apache.flume.clients.log4jappender.TestLog4jAppender

org.apache.flume.clients.log4jappender.TestLog4jAppenderWithAvro

org.apache.flume.conf.properties.PropertiesFileConfigurationProvider

org.apache.flume.Context

org.apache.flume.interceptor.InterceptorBuilderFactory

org.apache.flume.interceptor.InterceptorChain

org.apache.flume.interceptor.TestCensoringInterceptor

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.