'BatchProcessor constructor.
Args:
batch_size: All the values will be processed in batches of this size.
threadpool_prefix: Prefix that will be used in thread pool\'s threads
names.
threadpool_size: Size of a thread pool that will be used.
If threadpool_size is 0, no threads will be used
and all conversions will be done in the current
thread.'

def __init__(self, batch_size=1000, threadpool_prefix='batch_processor', threadpool_size=10):

    super(BatchConverter, self).__init__()
    self.batch_size = batch_size
    self.threadpool_prefix = threadpool_prefix
    self.threadpool_size = threadpool_size
