Commit 8470ff2a authored by Florian Fittkau's avatar Florian Fittkau

record batching now superfluous

parent f40d945e
...@@ -176,7 +176,7 @@ public class TCPWriter implements IPipeReceiver<ByteBufferEvent>, IWriter, ...@@ -176,7 +176,7 @@ public class TCPWriter implements IPipeReceiver<ByteBufferEvent>, IWriter,
} }
@Override @Override
public void processEvent(final ByteBufferEvent event) { public void processRecord(final ByteBufferEvent event) {
final ByteBuffer buffer = event.getValue(); final ByteBuffer buffer = event.getValue();
buffer.flip(); buffer.flip();
while ((socketChannel == null) || (!socketChannel.isConnected()) || !metaDataSent) { while ((socketChannel == null) || (!socketChannel.isConnected()) || !metaDataSent) {
...@@ -239,6 +239,6 @@ public class TCPWriter implements IPipeReceiver<ByteBufferEvent>, IWriter, ...@@ -239,6 +239,6 @@ public class TCPWriter implements IPipeReceiver<ByteBufferEvent>, IWriter,
@Override @Override
public void onEvent(final ByteBufferEvent arg0, final long arg1, final boolean arg2) public void onEvent(final ByteBufferEvent arg0, final long arg1, final boolean arg2)
throws Exception { throws Exception {
processEvent(arg0); processRecord(arg0);
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment