TokenizerFactory tokenizerFactory
int errors
boolean errorOnLast
List<E> extractors
int errors
boolean errorOnLast
Object defaultValue
TokenizerFactory scannerFactory
byte[] COLUMN_FAMILY_SOURCE
byte[] COLUMN_QUALIFIER_SOURCE_PLAY
byte[] COLUMN_QUALIFIER_SOURCE_QUOTE
byte[] COLUMN_FAMILY_TARGET
byte[] COLUMN_QUALIFIER_TARGET_TEXT
byte[] value
ByteArrayHelper helper
Class<T> cmpClass
GroupingOptions options
PGroupedTableType<K,V> ptype
SparkRuntimeContext ctxt
String jobName
org.apache.spark.broadcast.Broadcast<T> broadConf
org.apache.spark.Accumulator<T> counters
CombineFn<S,T> combineFn
SparkRuntimeContext ctxt
DoFn<S,T> fn
boolean convertInput
SparkRuntimeContext ctxt
DoFn<S,T> fn
SparkRuntimeContext ctxt
MapFn<S,T> fn
SparkRuntimeContext ctxt
boolean initialized
DoFn<S,T> fn
SparkRuntimeContext ctxt
MapFn<S,T> fn
SparkRuntimeContext ctxt
boolean initialized
MapFn<S,T> fn
SparkRuntimeContext runtimeContext
boolean initialized
SerDe<T> keySerde
SerDe<T> valueSerde
PGroupedTableType<K,V> ptype
Class<T> partitionerClass
int numPartitions
SparkRuntimeContext runtimeContext
GroupingOptions options
PGroupedTableType<K,V> ptype
SparkRuntimeContext ctxt
MapFn<S,T> fn
SparkRuntimeContext ctxt
boolean initialized
int vectorSize
int nbHash
JoinStrategy<K,U,V> delegateJoinStrategy
JoinStrategy<K,U,V> wrappedJoinStrategy
ShardedJoinStrategy.ShardingStrategy<K> shardingStrategy
int[] indices
String schemaJson
int[] indices
TupleFactory<T extends Tuple> tupleFactory
PTableType<K,V> tableType
TupleFactory<T extends Tuple> tupleFactory
List<E> elementTypes
ReadableData<T> delegate
DoFn<S,T> fn
Copyright © 2015 The Apache Software Foundation. All Rights Reserved.