...

Text file src/github.com/GoogleCloudPlatform/k8s-config-connector/config/samples/resources/dataflowflextemplatejob/streaming-dataflow-flex-template-job/dataflow_v1beta1_dataflowflextemplatejob.yaml

Documentation: github.com/GoogleCloudPlatform/k8s-config-connector/config/samples/resources/dataflowflextemplatejob/streaming-dataflow-flex-template-job

     1# Copyright 2020 Google LLC
     2#
     3# Licensed under the Apache License, Version 2.0 (the "License");
     4# you may not use this file except in compliance with the License.
     5# You may obtain a copy of the License at
     6#
     7#     http://www.apache.org/licenses/LICENSE-2.0
     8#
     9# Unless required by applicable law or agreed to in writing, software
    10# distributed under the License is distributed on an "AS IS" BASIS,
    11# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    12# See the License for the specific language governing permissions and
    13# limitations under the License.
    14
    15apiVersion: dataflow.cnrm.cloud.google.com/v1beta1
    16kind: DataflowFlexTemplateJob
    17metadata:
    18  annotations:
    19    cnrm.cloud.google.com/on-delete: "drain"
    20  name: dataflowflextemplatejob-sample-streaming
    21spec:
    22  region: us-central1
    23  # This is a public, Google-maintained Dataflow Job flex template of a streaming job
    24  containerSpecGcsPath: gs://dataflow-templates/2020-08-31-00_RC00/flex/PubSub_Avro_to_BigQuery
    25  parameters:
    26    # This is a public, Google-maintained Avro schema file expressly for this sample.
    27    schemaPath: gs://config-connector-samples/dataflowflextemplate/numbers.avsc
    28    # Replace ${PROJECT_ID?} with your project ID.
    29    inputSubscription: projects/${PROJECT_ID?}/subscriptions/dataflowflextemplatejob-dep-streaming
    30    outputTopic: projects/${PROJECT_ID?}/topics/dataflowflextemplatejob-dep1-streaming
    31    outputTableSpec: ${PROJECT_ID?}:dataflowflextemplatejobdepstreaming.dataflowflextemplatejobdepstreaming
    32    createDisposition: CREATE_NEVER

View as plain text