com.google.cloud.dataflow.sdk.io (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Package com.google.cloud.dataflow.sdk.io

Defines transforms for reading and writing common storage formats, including AvroIO, BigQueryIO, and TextIO.

See: Description

Package com.google.cloud.dataflow.sdk.io Description

Defines transforms for reading and writing common storage formats, including AvroIO, BigQueryIO, and TextIO.

The classes in this package provide Read transforms that create PCollections from existing storage:


 PCollection<TableRow> inputData = pipeline.apply(
     BigQueryIO.Read.named("Read")
                    .from("clouddataflow-readonly:samples.weather_stations");
 
and Write transforms that persist PCollections to external storage:
 
 PCollection<Integer> numbers = ...;
 numbers.apply(TextIO.Write.named("WriteNumbers")
                           .to("gs://my_bucket/path/to/numbers"));
  


¿Te ha resultado útil esta página? Enviar comentarios:

Enviar comentarios sobre...

Si necesitas ayuda, visita nuestra página de asistencia.