Examples of 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}.

Examples of org.apache.flume.channel.ChannelProcessor

    context.put("transactionCapacity", "1000");
    Configurables.configure(channel, context);
    rcs.setChannels(Lists.newArrayList(channel));


    source = new ExecSource();
    source.setChannelProcessor(new ChannelProcessor(rcs));
  }

View Full Code Here

0 1 2 3 4 5

TOP

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.