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

org.apache.flume.Channel.take()

Returns the next event from the channel if available. If the channel does not have any events available, this method must return {@code null}.

Note: This method must be invoked within an active {@link Transaction} boundary. Failure to do so can lead to unpredictableresults.
@return the next available event or {@code null} if no events areavailable. @throws ChannelException in case this operation fails. @see org.apache.flume.Transaction#begin()

    Transaction txn = channel.getTransaction();
    List<Row> actions = new LinkedList<Row>();
    List<Increment> incs = new LinkedList<Increment>();
    txn.begin();
    for(long i = 0; i < batchSize; i++) {
      Event event = channel.take();
      if(event == null){
        status = Status.BACKOFF;
        counterGroup.incrementAndGet("channel.underflow");
        break;
      } else {

View Full Code Here

    Transaction transaction = channel.getTransaction();
    Event event = null;


    try {
      transaction.begin();
      event = channel.take();


      if (event != null) {
        if (logger.isInfoEnabled()) {
          logger.info("Event: " + EventHelper.dumpEvent(event));
        }

View Full Code Here

      verifyConnection();


      List<Event> batch = Lists.newLinkedList();


      for (int i = 0; i < batchSize; i++) {
        Event event = channel.take();


        if (event == null) {
          counterGroup.incrementAndGet("batch.underflow");
          break;
        }

View Full Code Here

      long processedEvents = 0;


      transaction = channel.getTransaction();
      transaction.begin();
      for (; processedEvents < batchSize; processedEvents += 1) {
        Event event = channel.take();
        if (event == null) {
          // no events available in the channel
          break;
        }

View Full Code Here

        try {
            transaction = channel.getTransaction();
            transaction.begin();
            
            for(long i = 0; i < this.batchSize; i++) {
                Event event = channel.take();
                if(event == null){
                  status = Status.BACKOFF;
                  if (i == 0) {
                    sinkCounter.incrementBatchEmptyCount();
                  } else {

View Full Code Here

0 1 2 3 4 5 6 7 8

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.