public class SourceTranslationUtils extends Object
| Constructor and Description |
|---|
SourceTranslationUtils() |
| 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) |
public static Reader.Progress cloudProgressToReaderProgress(@Nullable com.google.api.services.dataflow.model.ApproximateProgress cloudProgress)
public static Reader.Position cloudPositionToReaderPosition(@Nullable com.google.api.services.dataflow.model.Position cloudPosition)
public static SourceFormat.OperationRequest cloudSourceOperationRequestToSourceOperationRequest(@Nullable com.google.api.services.dataflow.model.SourceOperationRequest request)
public static SourceFormat.OperationResponse cloudSourceOperationResponseToSourceOperationResponse(@Nullable com.google.api.services.dataflow.model.SourceOperationResponse response)
public static com.google.api.services.dataflow.model.ApproximateProgress readerProgressToCloudProgress(@Nullable Reader.Progress readerProgress)
public static com.google.api.services.dataflow.model.Position toCloudPosition(@Nullable Reader.Position readerPosition)
public static com.google.api.services.dataflow.model.SourceOperationRequest sourceOperationRequestToCloudSourceOperationRequest(@Nullable SourceFormat.OperationRequest request)
public static com.google.api.services.dataflow.model.SourceOperationResponse sourceOperationResponseToCloudSourceOperationResponse(@Nullable SourceFormat.OperationResponse response)
public static com.google.api.services.dataflow.model.Source sourceSpecToCloudSource(@Nullable SourceFormat.SourceSpec spec)
public static com.google.api.services.dataflow.model.ApproximateProgress splitRequestToApproximateProgress(@Nullable Reader.DynamicSplitRequest splitRequest)
public static Reader.DynamicSplitRequest toDynamicSplitRequest(@Nullable com.google.api.services.dataflow.model.ApproximateProgress approximateProgress)
public static Map<String,Object> cloudSourceToDictionary(com.google.api.services.dataflow.model.Source source)