com.google.cloud.dataflow.examples

Class PubsubFileInjector

java.lang.Object

com.google.cloud.dataflow.examples.PubsubFileInjector

public class PubsubFileInjector
extends java.lang.Object

A batch Dataflow pipeline for injecting a set of GCS files into a PubSub topic line by line.

This is useful for testing streaming pipelines. Note that since batch pipelines might retry chunks, this does _not_ guarantee exactly-once injection of file data. Some lines may be published multiple times.

Constructor Summary

Constructors

Constructor and Description
PubsubFileInjector()

Method Summary

Methods

Modifier and Type	Method and Description
static void	main(java.lang.String[] args) Sets up and starts streaming pipeline.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PubsubFileInjector

public PubsubFileInjector()

Method Detail

main

public static void main(java.lang.String[] args)

Sets up and starts streaming pipeline.