Serialized Form

Package org.apache.beam.sdk.extensions.gcp.options

Class org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer extends HashMap<String,String> implements Serializable

Package org.apache.beam.sdk.util

Class org.apache.beam.sdk.util.AppliedCombineFn extends Object implements Serializable

Serialized Fields

fn

CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> fn

accumulatorCoder

Coder<T> accumulatorCoder

sideInputViews

Iterable<T> sideInputViews

kvCoder

KvCoder<K,V> kvCoder

windowingStrategy

WindowingStrategy<T,W extends BoundedWindow> windowingStrategy

Class org.apache.beam.sdk.util.BitSetCoder extends CustomCoder<BitSet> implements Serializable

Class org.apache.beam.sdk.util.EmptyOnDeserializationThreadLocal extends ThreadLocal<T> implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream arg0)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream arg0)
                  throws IOException

Throws:

IOException

readObjectNoData

private void readObjectNoData()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Class org.apache.beam.sdk.util.ExplicitShardedFile extends Object implements Serializable

Serialized Fields

files

List<E> files

Class org.apache.beam.sdk.util.IdentityWindowFn extends NonMergingWindowFn<T,BoundedWindow> implements Serializable

Serialized Fields

coder

Coder<T> coder

Class org.apache.beam.sdk.util.IllegalMutationException extends RuntimeException implements Serializable

Serialized Fields

savedValue

Object savedValue

newValue

Object newValue

Class org.apache.beam.sdk.util.NumberedShardedFile extends Object implements Serializable

Serialized Fields

filePattern

String filePattern

shardTemplate

Pattern shardTemplate

Class org.apache.beam.sdk.util.PCollectionViews.IterableViewFn extends ViewFn<Iterable<WindowedValue<T>>,Iterable<T>> implements Serializable

Class org.apache.beam.sdk.util.PCollectionViews.ListViewFn extends ViewFn<Iterable<WindowedValue<T>>,List<T>> implements Serializable

Class org.apache.beam.sdk.util.PCollectionViews.MapViewFn extends ViewFn<Iterable<WindowedValue<KV<K,V>>>,Map<K,V>> implements Serializable

Class org.apache.beam.sdk.util.PCollectionViews.MultimapViewFn extends ViewFn<Iterable<WindowedValue<KV<K,V>>>,Map<K,Iterable<V>>> implements Serializable

Class org.apache.beam.sdk.util.PCollectionViews.SimplePCollectionView extends PValueBase implements Serializable

Serialized Fields

tag

TupleTag<V> tag

windowMappingFn

WindowMappingFn<TargetWindowT extends BoundedWindow> windowMappingFn

windowingStrategy

WindowingStrategy<T,W extends BoundedWindow> windowingStrategy

coder

Coder<T> coder

viewFn

ViewFn<PrimitiveViewT,ViewT> viewFn

Class org.apache.beam.sdk.util.PCollectionViews.SingletonViewFn extends ViewFn<Iterable<WindowedValue<T>>,T> implements Serializable

Serialized Fields

encodedDefaultValue

byte[] encodedDefaultValue

Deprecated.

valueCoder

Coder<T> valueCoder

Deprecated.

hasDefault

boolean hasDefault

Deprecated.

Class org.apache.beam.sdk.util.Reshuffle extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,V>>> implements Serializable

Class org.apache.beam.sdk.util.ReshuffleTrigger extends Trigger implements Serializable

Class org.apache.beam.sdk.util.UserCodeException extends RuntimeException implements Serializable

Class org.apache.beam.sdk.util.ValueWithRecordId.StripIdsDoFn extends DoFn<ValueWithRecordId<T>,T> implements Serializable

Class org.apache.beam.sdk.util.ValueWithRecordId.ValueWithRecordIdCoder extends CustomCoder<ValueWithRecordId<ValueT>> implements Serializable

Serialized Fields

valueCoder

Coder<T> valueCoder

idCoder

ByteArrayCoder idCoder

Class org.apache.beam.sdk.util.WindowedValue.FullWindowedValueCoder extends WindowedValue.WindowedValueCoder<T> implements Serializable

Serialized Fields

windowCoder

Coder<T> windowCoder

windowsCoder

Coder<T> windowsCoder

Class org.apache.beam.sdk.util.WindowedValue.ValueOnlyWindowedValueCoder extends WindowedValue.WindowedValueCoder<T> implements Serializable

Class org.apache.beam.sdk.util.WindowedValue.WindowedValueCoder extends StructuredCoder<WindowedValue<T>> implements Serializable

Serialized Fields

valueCoder

Coder<T> valueCoder

Class org.apache.beam.sdk.util.WindowingStrategy extends Object implements Serializable

Serialized Fields

windowFn

WindowFn<T,W extends BoundedWindow> windowFn

trigger

Trigger trigger

mode

WindowingStrategy.AccumulationMode mode

allowedLateness

org.joda.time.Duration allowedLateness

closingBehavior

Window.ClosingBehavior closingBehavior

timestampCombiner

TimestampCombiner timestampCombiner

triggerSpecified

boolean triggerSpecified

modeSpecified

boolean modeSpecified

allowedLatenessSpecified

boolean allowedLatenessSpecified

timestampCombinerSpecified

boolean timestampCombinerSpecified

Package org.apache.beam.sdk.util.gcsfs

Class org.apache.beam.sdk.util.gcsfs.GcsPath extends Object implements Serializable

Serialized Fields

bucket

String bucket

object

String object