FLUME-683 Add buffering to ThriftEventSource/Sink

Review Request #1843 - Created June 24, 2011 and submitted

Chetan Sarva
old-flume
FLUME-683
flume
Add input/output buffering to the source/sink thrift sockets


  1. A few nits.
    
    Did you run the tests and did they pass?
  2. spacing nits.  also, no @author tags please (your name will be in the commit log)
    1. Don't think it's necessary. This check is really only here for the case when the TBufferedSocket is initialized using an existing Socket (which may or may not be opened), and we don't currently use this initializer. 
  3. 
      
Review request changed
  1. lgtm.
  2. 
      
Loading...