com.google.cloud.dataflow.examples

Class PubsubFileInjector.Publish

java.lang.Object

com.google.cloud.dataflow.sdk.transforms.DoFn<java.lang.String,java.lang.Void>

com.google.cloud.dataflow.examples.PubsubFileInjector.Publish

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

PubsubFileInjector

public static class PubsubFileInjector.Publish
extends DoFn<java.lang.String,java.lang.Void>

A DoFn that publishes lines to Google Cloud PubSub.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.google.cloud.dataflow.sdk.transforms.DoFn

DoFn.Context, DoFn.KeyedState, DoFn.ProcessContext, DoFn.RequiresKeyedState, DoFn.RequiresWindowAccess

Field Summary

Fields

Modifier and Type	Field and Description
com.google.api.services.pubsub.Pubsub	pubsub

Constructor Summary

Constructors

Constructor and Description
PubsubFileInjector.Publish(java.lang.String outputTopic)

Method Summary

Methods

Modifier and Type	Method and Description
void	processElement(DoFn.ProcessContext c)
void	startBundle(DoFn.Context context)

Methods inherited from class com.google.cloud.dataflow.sdk.transforms.DoFn

finishBundle, getAllowedTimestampSkew

Methods inherited from class java.lang.Object

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

Field Detail

pubsub

public transient com.google.api.services.pubsub.Pubsub pubsub

Constructor Detail

PubsubFileInjector.Publish

public PubsubFileInjector.Publish(java.lang.String outputTopic)

Method Detail

startBundle

public void startBundle(DoFn.Context context)

Overrides:

startBundle in class DoFn<java.lang.String,java.lang.Void>

processElement

public void processElement(DoFn.ProcessContext c)
                    throws java.io.IOException

Specified by:

processElement in class DoFn<java.lang.String,java.lang.Void>

Throws:

java.io.IOException