| Class and Description |
|---|
| com.google.cloud.dataflow.sdk.transforms.Combine.SimpleCombineFn |
| Method and Description |
|---|
| com.google.cloud.dataflow.sdk.coders.Proto2Coder.addExtensionsFrom(Class<?>...) |
| com.google.cloud.dataflow.sdk.coders.Proto2Coder.addExtensionsFrom(Iterable<Class<?>>) |
| com.google.cloud.dataflow.sdk.transforms.Filter.by(PredicateT)
use
byPredicate, which returns a Filter transform instead of
a ParDo.Bound. |
| com.google.cloud.dataflow.sdk.options.PipelineOptionsFactory.createFromSystemProperties()
for internal use only
|
| com.google.cloud.dataflow.sdk.Pipeline.getFullNameForTesting(PTransform<?, ?>) |
| com.google.cloud.dataflow.sdk.testing.DataflowAssert.SingletonAssert.is(T)
replaced by
DataflowAssert.SingletonAssert.isEqualTo(T) |
| com.google.cloud.dataflow.sdk.transforms.Combine.SimpleCombineFn.of(SerializableFunction<Iterable<V>, V>) |
| com.google.cloud.dataflow.sdk.transforms.View.AsMap.withSingletonValues()
this method simply returns this AsMap unmodified
|
| Constructor and Description |
|---|
| com.google.cloud.dataflow.sdk.Pipeline(PipelineRunner<?>) |
| Enum Constant and Description |
|---|
| com.google.cloud.dataflow.sdk.options.DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType.BASIC |