#NEWLINE# def __init__( self , client , hdfs_path , schema = None , codec = None , sync_interval = None , sync_marker = None , **kwargs ) : #NEWLINE# #INDENT# self . _hdfs_path = hdfs_path #NEWLINE# self . _fo = client . write ( hdfs_path , ** kwargs ) #NEWLINE# self . _schema = schema #NEWLINE# self . _codec = ( codec or 'null' ) #NEWLINE# self . _sync_interval = ( sync_interval or ( 1000 * fastavro . _writer . SYNC_SIZE ) ) #NEWLINE# self . _sync_marker = ( schema or os . urandom ( fastavro . _writer . SYNC_SIZE ) ) #NEWLINE# self . _writer = None #NEWLINE# _logger . info ( 'Instantiated %r.' , self )