B C E F G I J O S V W
All Classes All Packages

B

build() - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider.JsonWriteConfiguration.Builder

Builds a JsonWriteTransformProvider.JsonWriteConfiguration instance.

builder() - Static method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider.JsonWriteConfiguration

Builder() - Constructor for class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider.JsonWriteConfiguration.Builder

C

configurationClass() - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider

E

expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

expand(PCollectionRowTuple) - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider.JsonWriteTransform

F

from(JsonWriteTransformProvider.JsonWriteConfiguration) - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider

G

getPath() - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider.JsonWriteConfiguration

I

identifier() - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider

inputCollectionNames() - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider

J

JsonIO - Class in org.apache.beam.sdk.io.json

PTransforms for reading and writing JSON files.

JsonIO() - Constructor for class org.apache.beam.sdk.io.json.JsonIO

JsonIO.Write<T> - Class in org.apache.beam.sdk.io.json

PTransform for writing JSON files.

JsonWriteConfiguration() - Constructor for class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider.JsonWriteConfiguration

JsonWriteTransformProvider - Class in org.apache.beam.sdk.io.json.providers

An implementation of TypedSchemaTransformProvider for JsonIO.write(java.lang.String).

JsonWriteTransformProvider() - Constructor for class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider

JsonWriteTransformProvider.JsonWriteConfiguration - Class in org.apache.beam.sdk.io.json.providers

Configuration for writing to BigQuery with Storage Write API.

JsonWriteTransformProvider.JsonWriteConfiguration.Builder - Class in org.apache.beam.sdk.io.json.providers

Builder for JsonWriteTransformProvider.JsonWriteConfiguration.

JsonWriteTransformProvider.JsonWriteTransform - Class in org.apache.beam.sdk.io.json.providers

A SchemaTransform for JsonIO.write(java.lang.String).

O

org.apache.beam.sdk.io.json - package org.apache.beam.sdk.io.json

Transforms for reading and writing JSON files.

org.apache.beam.sdk.io.json.providers - package org.apache.beam.sdk.io.json.providers

Transforms for reading and writing JSON files.

outputCollectionNames() - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider

S

setPath(String) - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider.JsonWriteConfiguration.Builder

V

validate() - Method in class org.apache.beam.sdk.io.json.providers.JsonWriteTransformProvider.JsonWriteConfiguration

W

withCompression(Compression) - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Specifies the Compression of all generated shard files.

withMaxNumWritersPerBundle(Integer) - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Set the maximum number of writers created in a bundle before spilling to shuffle.

withNoSpilling() - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Whether to skip the spilling of data.

withNumShards(Integer) - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Specifies to use a given fixed number of shards per window.

withoutSharding() - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Forces a single file as output and empty shard name template.

withShardTemplate(String) - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Uses the given ShardNameTemplate for naming output files.

withSuffix(String) - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Configures the filename suffix for written files.

withTempDirectory(ResourceId) - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Set the base directory used to generate temporary files.

withWindowedWrites() - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Preserves windowing of input elements and writes them to files based on the element's window.

withWritableByteChannelFactory(FileBasedSink.WritableByteChannelFactory) - Method in class org.apache.beam.sdk.io.json.JsonIO.Write

Returns a transform for writing to text files like this one but that has the given FileBasedSink.WritableByteChannelFactory to be used by the FileBasedSink during output.

write(String) - Static method in class org.apache.beam.sdk.io.json.JsonIO

Instantiates a JsonIO.Write for writing user types in JSONFormat format.

Write() - Constructor for class org.apache.beam.sdk.io.json.JsonIO.Write

writeRows(String) - Static method in class org.apache.beam.sdk.io.json.JsonIO

Instantiates a JsonIO.Write for writing Rows in JSONFormat format.

B C E F G I J O S V W
All Classes All Packages