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

Class SourceTranslationUtils

java.lang.Object

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

public class SourceTranslationUtils
extends Object

Utilities for representing input-specific objects using Dataflow model protos.

Constructor Summary

Constructors

Constructor and Description
SourceTranslationUtils()

Method Summary

Modifier and Type	Method and Description
static Reader.Position	cloudPositionToReaderPosition(com.google.api.services.dataflow.model.Position cloudPosition)
static Reader.Progress	cloudProgressToReaderProgress(com.google.api.services.dataflow.model.ApproximateProgress cloudProgress)
static SourceFormat.OperationRequest	cloudSourceOperationRequestToSourceOperationRequest(com.google.api.services.dataflow.model.SourceOperationRequest request)
static SourceFormat.OperationResponse	cloudSourceOperationResponseToSourceOperationResponse(com.google.api.services.dataflow.model.SourceOperationResponse response)
static Map<String,Object>	cloudSourceToDictionary(com.google.api.services.dataflow.model.Source source)
static com.google.api.services.dataflow.model.Source	dictionaryToCloudSource(Map<String,Object> params)
static com.google.api.services.dataflow.model.ApproximateProgress	readerProgressToCloudProgress(Reader.Progress readerProgress)
static com.google.api.services.dataflow.model.SourceOperationRequest	sourceOperationRequestToCloudSourceOperationRequest(SourceFormat.OperationRequest request)
static com.google.api.services.dataflow.model.SourceOperationResponse	sourceOperationResponseToCloudSourceOperationResponse(SourceFormat.OperationResponse response)
static com.google.api.services.dataflow.model.Source	sourceSpecToCloudSource(SourceFormat.SourceSpec spec)
static com.google.api.services.dataflow.model.ApproximateProgress	splitRequestToApproximateProgress(Reader.DynamicSplitRequest splitRequest)
static com.google.api.services.dataflow.model.Position	toCloudPosition(Reader.Position readerPosition)
static Reader.DynamicSplitRequest	toDynamicSplitRequest(com.google.api.services.dataflow.model.ApproximateProgress approximateProgress)

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceTranslationUtils

public SourceTranslationUtils()

Method Detail

cloudProgressToReaderProgress

public static Reader.Progress cloudProgressToReaderProgress(@Nullable
                                                            com.google.api.services.dataflow.model.ApproximateProgress cloudProgress)

cloudPositionToReaderPosition

public static Reader.Position cloudPositionToReaderPosition(@Nullable
                                                            com.google.api.services.dataflow.model.Position cloudPosition)

cloudSourceOperationRequestToSourceOperationRequest

public static SourceFormat.OperationRequest cloudSourceOperationRequestToSourceOperationRequest(@Nullable
                                                                                                com.google.api.services.dataflow.model.SourceOperationRequest request)

cloudSourceOperationResponseToSourceOperationResponse

public static SourceFormat.OperationResponse cloudSourceOperationResponseToSourceOperationResponse(@Nullable
                                                                                                   com.google.api.services.dataflow.model.SourceOperationResponse response)

readerProgressToCloudProgress

public static com.google.api.services.dataflow.model.ApproximateProgress readerProgressToCloudProgress(@Nullable
                                                                                                       Reader.Progress readerProgress)

toCloudPosition

public static com.google.api.services.dataflow.model.Position toCloudPosition(@Nullable
                                                                              Reader.Position readerPosition)

sourceOperationRequestToCloudSourceOperationRequest

public static com.google.api.services.dataflow.model.SourceOperationRequest sourceOperationRequestToCloudSourceOperationRequest(@Nullable
                                                                                                                                SourceFormat.OperationRequest request)

sourceOperationResponseToCloudSourceOperationResponse

public static com.google.api.services.dataflow.model.SourceOperationResponse sourceOperationResponseToCloudSourceOperationResponse(@Nullable
                                                                                                                                   SourceFormat.OperationResponse response)

sourceSpecToCloudSource

public static com.google.api.services.dataflow.model.Source sourceSpecToCloudSource(@Nullable
                                                                                    SourceFormat.SourceSpec spec)

splitRequestToApproximateProgress

public static com.google.api.services.dataflow.model.ApproximateProgress splitRequestToApproximateProgress(@Nullable
                                                                                                           Reader.DynamicSplitRequest splitRequest)

toDynamicSplitRequest

public static Reader.DynamicSplitRequest toDynamicSplitRequest(@Nullable
                                                               com.google.api.services.dataflow.model.ApproximateProgress approximateProgress)

cloudSourceToDictionary

public static Map<String,Object> cloudSourceToDictionary(com.google.api.services.dataflow.model.Source source)

dictionaryToCloudSource

public static com.google.api.services.dataflow.model.Source dictionaryToCloudSource(Map<String,Object> params)
                                                                             throws Exception

Throws:

Exception