<s> """<STR_LIT>""" <EOL> from __future__ import absolute_import <EOL> from google . cloud . dataflow import coders <EOL> from google . cloud . dataflow . io import iobase <EOL> class PubSubSource ( iobase . NativeSource ) : <EOL> """<STR_LIT>""" <EOL> def __init__ ( self , topic , subscription = None , id_label = None , <EOL> coder = coders . StrUtf8Coder ( ) ) : <EOL> self . topic = topic <EOL> self . subscription = subscription <EOL> self . id_label = id_label <EOL> self . coder = coder <EOL> @ property <EOL> def format ( self ) : <EOL> """<STR_LIT>""" <EOL> return '<STR_LIT>' <EOL> def reader ( self ) : <EOL> raise NotImplementedError ( <EOL> '<STR_LIT>' ) <EOL> class PubSubSink ( iobase . NativeSink ) : <EOL> """<STR_LIT>""" <EOL> def __init__ ( self , topic , coder = coders . StrUtf8Coder ( ) ) : <EOL> self . topic = topic <EOL> self . coder = coder <EOL> @ property <EOL> def format ( self ) : <EOL> """<STR_LIT>""" <EOL> return '<STR_LIT>' <EOL> def writer ( self ) : <EOL> raise NotImplementedError ( <EOL> '<STR_LIT>' ) </s>
