(self, record_processor, input_file=sys.stdin, output_file=sys.stdout, error_file=sys.stderr)
:type record_processor: RecordProcessorBase or amazon_kclpy.v2.processor.RecordProcessorBase
        :param record_processor: A record processor to use for processing a shard.

        :param file input_file: A file to read action messages from. Typically STDIN.

        :param file output_file: A file to write action messages to. Typically STDOUT.

        :param file error_file: A file to write error messages to. Typically STDERR.
:type record_processor: RecordProcessorBase or amazon_kclpy.v2.processor.RecordProcessorBase
        :param record_processor: A record processor to use for processing a shard.
: type record_processor : RecordProcessorBase or amazon_kclpy . v2 . processor . RecordProcessorBase : param record_processor : A record processor to use for processing a shard .
def __init__(self, record_processor, input_file=sys.stdin, output_file=sys.stdout, error_file=sys.stderr):
        """
        :type record_processor: RecordProcessorBase or amazon_kclpy.v2.processor.RecordProcessorBase
        :param record_processor: A record processor to use for processing a shard.

        :param file input_file: A file to read action messages from. Typically STDIN.

        :param file output_file: A file to write action messages to. Typically STDOUT.

        :param file error_file: A file to write error messages to. Typically STDERR.
        """
        self.io_handler = _IOHandler(input_file, output_file, error_file)
        self.checkpointer = Checkpointer(self.io_handler)
        if record_processor.version == 2:
            self.processor = v3processor.V2toV3Processor(record_processor)
        elif record_processor.version == 1:
            self.processor = v3processor.V2toV3Processor(v2processor.V1toV2Processor(record_processor))
        else:
            self.processor = record_processor
def __init__ ( self , record_processor , input_file = sys . stdin , output_file = sys . stdout , error_file = sys . stderr ) : self . io_handler = _IOHandler ( input_file , output_file , error_file ) self . checkpointer = Checkpointer ( self . io_handler ) if record_processor . version == 2 : self . processor = v3processor . V2toV3Processor ( record_processor ) elif record_processor . version == 1 : self . processor = v3processor . V2toV3Processor ( v2processor . V1toV2Processor ( record_processor ) ) else : self . processor = record_processor