org.apache.beam.sdk.transforms

Class GroupIntoBatches.BatchingParams

java.lang.Object

org.apache.beam.sdk.transforms.GroupIntoBatches.BatchingParams

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

GroupIntoBatches<K,InputT>

public abstract static class GroupIntoBatches.BatchingParams
extends java.lang.Object
implements java.io.Serializable

Wrapper class for batching parameters supplied by users. Shared by both GroupIntoBatches and GroupIntoBatches.WithShardedKey.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BatchingParams()

Method Summary

Modifier and Type	Method and Description
static GroupIntoBatches.BatchingParams	create(long batchSize, Duration maxBufferingDuration)
abstract long	getBatchSize()
abstract Duration	getMaxBufferingDuration()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchingParams

public BatchingParams()

Method Detail

create

public static GroupIntoBatches.BatchingParams create(long batchSize,
                                                     Duration maxBufferingDuration)

getBatchSize

public abstract long getBatchSize()

getMaxBufferingDuration

public abstract Duration getMaxBufferingDuration()