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

Class SourceOperationExecutorFactory

java.lang.Object

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

public class SourceOperationExecutorFactory
extends Object

Creates a SourceOperationExecutor from a SourceOperation.

Constructor Summary

Constructors

Constructor and Description
SourceOperationExecutorFactory()

Method Summary

Modifier and Type	Method and Description
static SourceOperationExecutor	create(PipelineOptions options, com.google.api.services.dataflow.model.SourceOperationRequest request)

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceOperationExecutorFactory

public SourceOperationExecutorFactory()

Method Detail

create

public static SourceOperationExecutor create(PipelineOptions options,
                                             com.google.api.services.dataflow.model.SourceOperationRequest request)
                                      throws Exception

Throws:

Exception