String id
ExecutionPropertyMap executionProperties
Coder<T> coder
Boolean isSideInput
ExecutionProperty.Key key
Object value
ExecutionPropertyMap executionProperties
DAGBuilder<V extends Vertex,E extends Edge<V>> builder
String compositeTransformFullName
Map<K,V> dagIncomingEdges
Map<K,V> iterativeIncomingEdges
Map<K,V> nonIterativeIncomingEdges
Map<K,V> dagOutgoingEdges
Map<K,V> edgeWithLoopToEdgeWithInternalVertex
Map<K,V> edgeWithInternalVertexToEdgeWithLoop
Integer maxNumberOfIterations
IntPredicate terminationCondition
OutputCollector<O> outputCollector
org.apache.beam.sdk.coders.Coder<T> beamCoder
org.apache.beam.sdk.coders.Coder<T> leftCoder
org.apache.beam.sdk.coders.Coder<T> rightCoder
org.apache.beam.sdk.io.BoundedSource<T> source
org.apache.beam.sdk.values.PCollectionView<T> pCollectionView
OutputCollector<O> outputCollector
List<E> windowed
org.apache.beam.sdk.transforms.ViewFn<PrimitiveViewT,ViewT> viewFn
ArrayList<E> collectedElements
OutputCollector<O> outputCollector
Map<K,V> keyToValues
OutputCollector<O> outputCollector
org.apache.beam.sdk.transforms.windowing.WindowFn<T,W extends org.apache.beam.sdk.transforms.windowing.BoundedWindow> windowFn
OutputCollector<O> outputCollector
org.apache.spark.serializer.Serializer serializer
ReadablesWrapper<O> readablesWrapper
String filename
org.apache.spark.api.java.function.FlatMapFunction<T,R> func
OutputCollector<O> oc
Map<K,V> keyToValues
OutputCollector<O> oc
org.apache.spark.api.java.function.PairFunction<T,K,V> func
OutputCollector<O> oc
org.apache.spark.api.java.function.Function<T1,R> func
OutputCollector<O> oc
Map<K,V> keyToValues
org.apache.spark.api.java.function.Function2<T1,T2,R> func
OutputCollector<O> oc
org.apache.spark.api.java.function.Function2<T1,T2,R> func
OutputCollector<O> oc
String name
String name
ExecutionProperty.Key keyOfExecutionPropertyToModify
Set<E> prerequisiteExecutionProperties
CompressionProperty.Compression compression
int desiredSourceParallelism
int shuffleDecreaseFactor
Policy policy
Policy policy
Policy policy
Policy policy
Policy policy
Policy policy
Boolean isUserData
int rangeBeginInclusive
int rangeEndExclusive
String blockId
BlockState.State state
ExecutionPropertyMap edgeProperties
Coder<T> coder
Boolean isSideInput
ReadablesWrapper<O> readableWrapper
String jobId
String taskGroupId
int taskGroupIdx
List<E> taskGroupIncomingEdges
List<E> taskGroupOutgoingEdges
int attemptIdx
String containerType
byte[] serializedTaskGroupDag
String irVertexId
String path
long position
long count
AtomicReference<V> outputList
Copyright © 2018. All rights reserved.