int count
int id
String procId
int numMessages
BlockingQueue<E> data
boolean complete
StreamsDatumConverter converter
String fileName
List<E> expectedDatums
int counted
int expectedSize
String fileName
Scanner scanner
StreamsDatumConverter converter
Copyright © 2012–2016 The Apache Software Foundation. All rights reserved.