com.google.cloud.dataflow.sdk.util.common.worker

Interface SourceFormat

All Known Implementing Classes:

BasicSerializableSourceFormat

public interface SourceFormat

An interface for sources that can perform operations on source specifications, such as splitting the source and computing its metadata. See SourceOperationRequest for details.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	SourceFormat.OperationRequest A representation of an operation on the specification of a source, e.g.
static interface	SourceFormat.OperationResponse A representation of the result of a SourceOperationRequest.
static interface	SourceFormat.SourceSpec A representation of a specification of a source.

Method Summary

Modifier and Type	Method and Description
SourceFormat.OperationResponse	performSourceOperation(SourceFormat.OperationRequest operation) Performs an operation on the specification of a source.

Method Detail

performSourceOperation

SourceFormat.OperationResponse performSourceOperation(SourceFormat.OperationRequest operation)
                                               throws Exception

Performs an operation on the specification of a source. See SourceOperationRequest for details.

Throws:

Exception