com.google.cloud.dataflow.sdk.runners.worker

Class SourceFormatFactory

java.lang.Object

com.google.cloud.dataflow.sdk.runners.worker.SourceFormatFactory

public class SourceFormatFactory
extends Object

Creates SourceFormat objects from Source.

Method Summary

Modifier and Type	Method and Description
static SourceFormat	create(PipelineOptions options, com.google.api.services.dataflow.model.Source source)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static SourceFormat create(PipelineOptions options,
                                  com.google.api.services.dataflow.model.Source source)
                           throws Exception

Throws:

Exception