Examples of ResettableInputStream

com.amazonaws.internal.ResettableInputStream
A mark-and-resettable input stream that can be used on files or file input streams. In particular, a {@link ResettableInputStream} allows the close operation tobe disabled via {@link #disableClose()} (to avoid accidentally being closed).This is necessary when such input stream needs to be marked-and-reset multiple times but only as long as the stream has not been closed.
The creator of this input stream should therefore always call {@link #release()} in a finally block to truly release the underlyingresources. @see Releasable
org.apache.flume.serialization.ResettableInputStream

This abstract class defines an interface for which the stream may be marked and reset with no limit to the number of bytes which may have been read between the calls.
Any implementation of this interface guarantees that the mark position will not be invalidated by reading any number of bytes.
Warning: We reserve the right to add public methods to this class in the future. Third-party subclasses beware.

Examples of org.apache.flume.serialization.ResettableInputStream

    validateMiniParse(des);
  }


  @Test
  public void testBatch() throws IOException {
    ResettableInputStream in = new ResettableTestStringInputStream(mini);
    EventDeserializer des = new BlobDeserializer(new Context(), in);
    List<Event> events;


    events = des.readEvents(10); // try to read more than we should have
    assertEquals(1, events.size());

View Full Code Here

Examples of org.apache.flume.serialization.ResettableInputStream

  public void testMaxLineLength() throws IOException {
    String longLine = "abcdefghijklmnopqrstuvwxyz\n";
    Context ctx = new Context();
    ctx.put(BlobDeserializer.MAX_BLOB_LENGTH_KEY, "10");


    ResettableInputStream in = new ResettableTestStringInputStream(longLine);
    EventDeserializer des = new BlobDeserializer(ctx, in);


    assertEventBodyEquals("abcdefghij", des.readEvent());
    assertEventBodyEquals("klmnopqrst", des.readEvent());
    assertEventBodyEquals("uvwxyz\n", des.readEvent());

View Full Code Here

0 1 2

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.