Examples of org.apache.flume.Transaction.begin()

org.apache.flume.Transaction.begin()

Starts a transaction boundary for the current channel operation. If a transaction is already in progress, this method will join that transaction using reference counting.

Note: For every invocation of this method there must be a corresponding invocation of {@linkplain #close()} method. Failureto ensure this can lead to dangling transactions and unpredictable results.

    server.close();
    Thread.sleep(500L); // sleep a little to allow close occur


    Transaction transaction = channel.getTransaction();


    transaction.begin();
    for (int i = 0; i < 10; i++) {
      channel.put(event);
    }
    transaction.commit();
    transaction.close();

View Full Code Here

    parms.put("byteCapacityBufferPercentage", "20");
    context.putAll(parms);
    Configurables.configure(channel,  context);


    Transaction tx = channel.getTransaction();
    tx.begin();
    //This line would cause a NPE without FLUME-1622.
    channel.put(EventBuilder.withBody(null));
    tx.commit();
    tx.close();

View Full Code Here


    Configurables.configure(source, context);
    source.start();


    Transaction transaction = channel.getTransaction();
    transaction.begin();


    for (int lineNumber = 0; lineNumber < 3; lineNumber++) {
        outputStream.write((eventBody).getBytes());
        outputStream.write(String.valueOf(lineNumber).getBytes());
        outputStream.write('\n');

View Full Code Here

    channel.put(EventBuilder.withBody(null));
    tx.commit();
    tx.close();


    tx = channel.getTransaction();
    tx.begin();
    channel.put(EventBuilder.withBody(new byte[0]));
    tx.commit();
    tx.close();

View Full Code Here

    Configurables.configure(sink, context);
    sink.start();
    RpcClient firstClient = sink.getUnderlyingClient();
    Thread.sleep(6000);
    Transaction t = channel.getTransaction();
    t.begin();
    channel.put(EventBuilder.withBody("This is a test", Charset.defaultCharset()));
    t.commit();
    t.close();
    sink.process();
    // Make sure they are not the same object, connection should be reset

View Full Code Here

      source.start();
      // Some commands might take longer to complete, specially on Windows
      // or on slow environments (e.g. Travis CI).
      Thread.sleep(2500);
      Transaction transaction = channel.getTransaction();
      transaction.begin();
      try {
        List<String> output = Lists.newArrayList();
        Event event;
        while ((event = channel.take()) != null) {
          output.add(new String(event.getBody(), Charset.defaultCharset()));

View Full Code Here

    Assert.assertTrue(LifecycleController.waitForOneOf(sink,
        LifecycleState.START_OR_ERROR, 5000));


    Transaction transaction = channel.getTransaction();


    transaction.begin();
    for (int i = 0; i < 10; i++) {
      channel.put(event);
    }
    transaction.commit();
    transaction.close();

View Full Code Here

    Configurables.configure(source, context);


    source.start();
    Transaction transaction = channel.getTransaction();


    transaction.begin();


    long start = System.currentTimeMillis();


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

View Full Code Here

    Assert.assertTrue(LifecycleController.waitForOneOf(sink,
        LifecycleState.START_OR_ERROR, 5000));


    Transaction transaction = channel.getTransaction();


    transaction.begin();
    for (int i = 0; i < 10; i++) {
      channel.put(event);
    }
    transaction.commit();
    transaction.close();

View Full Code Here

    Configurables.configure(sink, context);
    sink.start();


    Transaction sickTransaction = channel.getTransaction();


    sickTransaction.begin();
    for (int i = 0; i < 10; i++) {
      channel.put(event);
    }
    sickTransaction.commit();
    sickTransaction.close();

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.