sbrinkerhoff
diff --git a/‎gcloud/bigquery/job.py‎
Lines changed: 189 additions & 0 deletions b/‎gcloud/bigquery/job.py‎
Lines changed: 189 additions & 0 deletions
@@ -939,3 +939,192 @@ def _build_resource(self):
         self._populate_config_resource(configuration)
 
         return resource
+
+
+class _ExtractConfiguration(object):
+    """User-settable configuration options for extract jobs."""
+    # None -> use server default.
+    _compression = None
+    _destination_format = None
+    _field_delimiter = None
+    _print_header = None
+
+
+class Compression(_Enum):
+    """Pseudo-enum for allowed values for ``compression`` properties.
+    """
+    GZIP = 'GZIP'
+    NONE = 'NONE'
+    ALLOWED = (GZIP, NONE)
+
+
+class DestinationFormat(_Enum):
+    """Pseudo-enum for allowed values for ``destination_format`` properties.
+    """
+    CSV = 'CSV'
+    NEWLINE_DELIMITED_JSON = 'NEWLINE_DELIMITED_JSON'
+    AVRO = 'AVRO'
+    ALLOWED = (CSV, NEWLINE_DELIMITED_JSON, AVRO)
+
+
+class ExtractTableToStorageJob(_BaseJob):
+    """Asynchronous job: extract data from a BQ table into Cloud Storage.
+
+    :type name: string
+    :param name: the name of the job
+
+    :type source: :class:`gcloud.bigquery.table.Table`
+    :param source: Table into which data is to be loaded.
+
+    :type destination_uris: list of string
+    :param destination_uris: URIs describing Cloud Storage blobs into which
+                             extracted data will be written.
+
+    :type client: :class:`gcloud.bigquery.client.Client`
+    :param client: A client which holds credentials and project configuration
+                   for the dataset (which requires a project).
+    """
+    def __init__(self, name, source, destination_uris, client):
+        super(ExtractTableToStorageJob, self).__init__(name, client)
+        self.source = source
+        self.destination_uris = destination_uris
+        self._configuration = _ExtractConfiguration()
+
+    @property
+    def compression(self):
+        """Compression to apply to destination blobs.
+
+        :rtype: string, or ``NoneType``
+        :returns: The value as set by the user, or None (the default).
+        """
+        return self._configuration._compression
+
+    @compression.setter
+    def compression(self, value):
+        """Update compression.
+
+        :type value: boolean
+        :param value: allowed value for :class:`Compression`.
+        """
+        Compression.validate(value)  # raises ValueError if invalie
+        self._configuration._compression = value
+
+    @compression.deleter
+    def compression(self):
+        """Delete compression."""
+        del self._configuration._compression
+
+    @property
+    def destination_format(self):
+        """Handling for missing destination table.
+
+        :rtype: string, or ``NoneType``
+        :returns: The value as set by the user, or None (the default).
+        """
+        return self._configuration._destination_format
+
+    @destination_format.setter
+    def destination_format(self, value):
+        """Update destination_format.
+
+        :type value: boolean
+        :param value: allowed value for :class:`DestinationFormat`.
+        """
+        DestinationFormat.validate(value)  # raises ValueError if invalid
+        self._configuration._destination_format = value
+
+    @destination_format.deleter
+    def destination_format(self):
+        """Delete destination_format."""
+        del self._configuration._destination_format
+
+    @property
+    def field_delimiter(self):
+        """Allow rows with missing trailing commas for optional fields.
+
+        :rtype: string, or ``NoneType``
+        :returns: The value as set by the user, or None (the default).
+        """
+        return self._configuration._field_delimiter
+
+    @field_delimiter.setter
+    def field_delimiter(self, value):
+        """Update field_delimiter.
+
+        :type value: string
+        :param value: new field delimiter
+
+        :raises: ValueError for invalid value types.
+        """
+        if not isinstance(value, six.string_types):
+            raise ValueError("Pass a string")
+        self._configuration._field_delimiter = value
+
+    @field_delimiter.deleter
+    def field_delimiter(self):
+        """Delete field_delimiter."""
+        del self._configuration._field_delimiter
+
+    @property
+    def print_header(self):
+        """Write a header row into destination blobs.
+
+        :rtype: boolean, or ``NoneType``
+        :returns: The value as set by the user, or None (the default).
+        """
+        return self._configuration._print_header
+
+    @print_header.setter
+    def print_header(self, value):
+        """Update print_header.
+
+        :type value: boolean
+        :param value: new print_header
+
+        :raises: ValueError for invalid value types.
+        """
+        if not isinstance(value, bool):
+            raise ValueError("Pass a boolean")
+        self._configuration._print_header = value
+
+    @print_header.deleter
+    def print_header(self):
+        """Delete print_header."""
+        del self._configuration._print_header
+
+    def _populate_config_resource(self, configuration):
+
+        if self.compression is not None:
+            configuration['compression'] = self.compression
+        if self.destination_format is not None:
+            configuration['destinationFormat'] = self.destination_format
+        if self.field_delimiter is not None:
+            configuration['fieldDelimiter'] = self.field_delimiter
+        if self.print_header is not None:
+            configuration['printHeader'] = self.print_header
+
+    def _build_resource(self):
+        """Generate a resource for ``begin``."""
+
+        source_ref = {
+            'projectId': self.source.project,
+            'datasetId': self.source.dataset_name,
+            'tableId': self.source.name,
+        }
+
+        resource = {
+            'jobReference': {
+                'projectId': self.project,
+                'jobId': self.name,
+            },
+            'configuration': {
+                'extract': {
+                    'sourceTable': source_ref,
+                    'destinationUris': self.destination_uris,
+                },
+            },
+        }
+        configuration = resource['configuration']['extract']
+        self._populate_config_resource(configuration)
+
+        return resource