public class ConcatReaderFactory extends Object
ConcatReader from a CloudObject spec.| Constructor and Description |
|---|
ConcatReaderFactory() |
| Modifier and Type | Method and Description |
|---|---|
static <T> Reader<T> |
create(PipelineOptions options,
CloudObject spec,
Coder<T> coder,
ExecutionContext executionContext) |
static com.google.api.services.dataflow.model.Source |
createSourceFromDictionary(Map<String,Object> dictionary) |
public static <T> Reader<T> create(PipelineOptions options, CloudObject spec, Coder<T> coder, ExecutionContext executionContext) throws Exception
Exception