Package org.apache.flume

Examples of org.apache.flume.Channel.start()

207
208
209
210
211
212
213
214
215
216
217
      true, false);
    Configurables.configure(sink, ctx);
    Channel channel = new MemoryChannel();
    Configurables.configure(channel, ctx);
    sink.setChannel(channel);
    channel.start();
    sink.start();
    Transaction tx = channel.getTransaction();
    tx.begin();
    for(int i = 0; i < 3; i++){
      Event e = EventBuilder.withBody(Bytes.toBytes(valBase + "-" + i));
View Full Code Here
722
723
724
725
726
727
728
729
730
731
732
    Context channelCtx = new Context();
    channelCtx.put("capacity", String.valueOf(1000L));
    channelCtx.put("transactionCapacity", String.valueOf(1000L));
    Configurables.configure(channel, channelCtx);
    sink.setChannel(channel);
    channel.start();
    return channel;
  }

  private void putEvents(Channel channel, Iterable<Event> events) {
    Transaction tx = channel.getTransaction();
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
    Context context = new Context();
    Configurables.configure(s1, context);
    Configurables.configure(s2, context);
    Configurables.configure(s3, context);
    Configurables.configure(ch, context);
    ch.start();
    List<Sink> sinks = new LinkedList<Sink>();
    sinks.add(s1);
    sinks.add(s2);
    sinks.add(s3);
    SinkGroup group = new SinkGroup(sinks);
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
    Context context = new Context();
    Configurables.configure(s1, context);
    Configurables.configure(s2, context);
    Configurables.configure(s3, context);
    Configurables.configure(ch, context);
    ch.start();
    List<Sink> sinks = new LinkedList<Sink>();
    sinks.add(s1);
    sinks.add(s2);
    sinks.add(s3);
    SinkGroup group = new SinkGroup(sinks);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.