|
|||||||||
PREV NEXT | FRAMES NO FRAMES |
cascading.cascade.* |
---|
cascading.cascade.CascadeProps | ||
---|---|---|
public static final String |
MAX_CONCURRENT_FLOWS |
"cascading.cascade.maxconcurrentflows" |
cascading.flow.* |
---|
cascading.flow.Flow<Config> | ||
---|---|---|
public static final String |
CASCADING_FLOW_ID |
"cascading.flow.id" |
cascading.flow.FlowConnectorProps | ||
---|---|---|
public static final String |
ASSERTION_LEVEL |
"cascading.flowconnector.assertionlevel" |
public static final String |
CHECKPOINT_TAP_DECORATOR_CLASS |
"cascading.flowconnector.checkpoint_tap.decorator.classname" |
public static final String |
DEBUG_LEVEL |
"cascading.flowconnector.debuglevel" |
public static final String |
INTERMEDIATE_SCHEME_CLASS |
"cascading.flowconnector.intermediateschemeclass" |
public static final String |
TEMPORARY_TAP_DECORATOR_CLASS |
"cascading.flowconnector.temporary_tap.decorator.classname" |
cascading.flow.FlowDescriptors | ||
---|---|---|
public static final String |
DESCRIPTION |
"description" |
public static final String |
STATEMENTS |
"statements" |
public static final String |
VALUE_SEPARATOR |
"\u001e" |
cascading.flow.FlowProps | ||
---|---|---|
public static final String |
DEFAULT_ELEMENT_COMPARATOR |
"cascading.flow.tuple.element.comparator" |
public static final String |
JOB_POLLING_INTERVAL |
"cascading.flow.job.pollinginterval" |
public static final String |
MAX_CONCURRENT_STEPS |
"cascading.flow.maxconcurrentsteps" |
public static final String |
PRESERVE_TEMPORARY_FILES |
"cascading.flow.preservetemporaryfiles" |
public static final String |
STOP_JOBS_ON_EXIT |
"cascading.flow.stopjobsonexit" |
cascading.flow.FlowStep<Config> | ||
---|---|---|
public static final String |
CASCADING_FLOW_STEP_ID |
"cascading.flow.step.id" |
cascading.flow.hadoop.util.ObjectSerializer | ||
---|---|---|
public static final String |
OBJECT_SERIALIZER_PROPERTY |
"cascading.util.serializer" |
cascading.management.* |
---|
cascading.management.CascadingServices | ||
---|---|---|
public static final String |
CASCADING_SERVICES |
"cascading-service.properties" |
public static final String |
CASCADING_SERVICES_JAR |
"cascading.management.service.jar" |
public static final String |
CONTAINER_ENABLED |
"cascading.management.container.enabled" |
public static final String |
CONTAINER_EXCLUDE |
"cascading.management.container.exclude" |
public static final String |
DEFAULT_PROPERTIES |
"cascading/management/service.properties" |
cascading.management.DocumentService | ||
---|---|---|
public static final String |
DOCUMENT_SERVICE_CLASS_PROPERTY |
"cascading.management.document.service.classname" |
cascading.management.MetricsService | ||
---|---|---|
public static final String |
METRICS_SERVICE_CLASS_PROPERTY |
"cascading.management.metrics.service.classname" |
cascading.management.annotation.URISanitizer | ||
---|---|---|
public static final String |
FAILURE_MODE_PASS_THROUGH |
"cascading.management.annotation.urisanitizer.failurepassthrough" |
public static final String |
PARAMETER_FILTER_PROPERTY |
"cascading.management.annotation.urisanitizer.parameternames" |
cascading.management.state.ClientState | ||
---|---|---|
public static final String |
STATE_SERVICE_CLASS_PROPERTY |
"cascading.management.state.service.classname" |
cascading.operation.* |
---|
cascading.operation.Operation<Context> | ||
---|---|---|
public static final int |
ANY |
2147483647 |
cascading.operation.aggregator.Average | ||
---|---|---|
public static final String |
FIELD_NAME |
"average" |
cascading.operation.aggregator.Count | ||
---|---|---|
public static final String |
FIELD_NAME |
"count" |
cascading.operation.aggregator.Max | ||
---|---|---|
public static final String |
FIELD_NAME |
"max" |
cascading.operation.aggregator.MaxValue | ||
---|---|---|
public static final String |
FIELD_NAME |
"max" |
cascading.operation.aggregator.Min | ||
---|---|---|
public static final String |
FIELD_NAME |
"min" |
cascading.operation.aggregator.MinValue | ||
---|---|---|
public static final String |
FIELD_NAME |
"min" |
cascading.operation.aggregator.Sum | ||
---|---|---|
public static final String |
FIELD_NAME |
"sum" |
cascading.operation.text.DateFormatter | ||
---|---|---|
public static final String |
FIELD_NAME |
"datetime" |
cascading.operation.text.DateParser | ||
---|---|---|
public static final String |
FIELD_NAME |
"ts" |
cascading.operation.text.FieldFormatter | ||
---|---|---|
public static final String |
FIELD_NAME |
"formatted" |
cascading.operation.text.FieldJoiner | ||
---|---|---|
public static final String |
FIELD_NAME |
"joined" |
cascading.pipe.* |
---|
cascading.pipe.assembly.AggregateBy | ||
---|---|---|
public static final String |
AGGREGATE_BY_THRESHOLD |
"cascading.aggregateby.threshold" |
public static final int |
DEFAULT_THRESHOLD |
10000 |
public static final int |
USE_DEFAULT_THRESHOLD |
0 |
cascading.pipe.assembly.AggregateBy.CompositeFunction | ||
---|---|---|
public static final int |
DEFAULT_THRESHOLD |
10000 |
cascading.pipe.assembly.AverageBy | ||
---|---|---|
public static final int |
DEFAULT_THRESHOLD |
10000 |
cascading.pipe.assembly.CountBy | ||
---|---|---|
public static final int |
DEFAULT_THRESHOLD |
10000 |
cascading.pipe.assembly.MaxBy | ||
---|---|---|
public static final int |
DEFAULT_THRESHOLD |
10000 |
cascading.pipe.assembly.MinBy | ||
---|---|---|
public static final int |
DEFAULT_THRESHOLD |
10000 |
cascading.pipe.assembly.SumBy | ||
---|---|---|
public static final int |
DEFAULT_THRESHOLD |
10000 |
cascading.property.* |
---|
cascading.property.AppProps | ||
---|---|---|
public static final String |
APP_FRAMEWORKS |
"cascading.app.frameworks" |
public static final String |
APP_ID |
"cascading.app.id" |
public static final String |
APP_JAR_CLASS |
"cascading.app.appjar.class" |
public static final String |
APP_JAR_PATH |
"cascading.app.appjar.path" |
public static final String |
APP_NAME |
"cascading.app.name" |
public static final String |
APP_TAGS |
"cascading.app.tags" |
public static final String |
APP_VERSION |
"cascading.app.version" |
cascading.scheme.* |
---|
cascading.scheme.hadoop.TextDelimited | ||
---|---|---|
public static final String |
DEFAULT_CHARSET |
"UTF-8" |
cascading.scheme.hadoop.TextLine | ||
---|---|---|
public static final String |
DEFAULT_CHARSET |
"UTF-8" |
cascading.scheme.local.TextDelimited | ||
---|---|---|
public static final String |
DEFAULT_CHARSET |
"UTF-8" |
cascading.scheme.local.TextLine | ||
---|---|---|
public static final String |
DEFAULT_CHARSET |
"UTF-8" |
cascading.stats.* |
---|
cascading.stats.CascadingStats | ||
---|---|---|
public static final String |
STATS_STORE_INTERVAL |
"cascading.stats.store.interval" |
cascading.stats.hadoop.HadoopStepStats | ||
---|---|---|
public static final String |
COUNTER_TIMEOUT_PROPERTY |
"cascading.step.counter.timeout" |
public static final int |
TIMEOUT_MAX |
3 |
cascading.tap.* |
---|
cascading.tap.BaseTemplateTap<Config,Output> | ||
---|---|---|
protected static final int |
OPEN_TAPS_THRESHOLD_DEFAULT |
300 |
cascading.tap.hadoop.Hfs | ||
---|---|---|
public static final String |
TEMPORARY_DIRECTORY |
"cascading.tmp.dir" |
cascading.tap.hadoop.HfsProps | ||
---|---|---|
public static final String |
COMBINE_INPUT_FILES |
"cascading.hadoop.hfs.combine.files" |
public static final String |
COMBINE_INPUT_FILES_SAFE_MODE |
"cascading.hadoop.hfs.combine.safemode" |
public static final String |
COMBINE_INPUT_FILES_SIZE_MAX |
"cascading.hadoop.hfs.combine.max.size" |
public static final String |
LOCAL_MODE_SCHEME |
"cascading.hadoop.localmode.scheme" |
public static final String |
TEMPORARY_DIRECTORY |
"cascading.tmp.dir" |
cascading.tap.hadoop.io.CombineFileRecordReaderWrapper<K,V> | ||
---|---|---|
public static final String |
INDIVIDUAL_INPUT_FORMAT |
"cascading.individual.input.format" |
cascading.tap.hadoop.io.HttpFileSystem | ||
---|---|---|
public static final String |
HTTP_SCHEME |
"http" |
public static final String |
HTTPS_SCHEME |
"https" |
cascading.tap.hadoop.io.MultiInputSplit | ||
---|---|---|
public static final String |
CASCADING_SOURCE_PATH |
"cascading.source.path" |
cascading.tap.hadoop.io.TapOutputCollector | ||
---|---|---|
public static final String |
PART_TASK_PATTERN |
"%s%spart-%05d" |
public static final String |
PART_TASK_SEQ_PATTERN |
"%s%spart-%05d-%05d" |
cascading.tap.hadoop.util.Hadoop18TapUtil | ||
---|---|---|
public static final String |
TEMPORARY_PATH |
"_temporary" |
cascading.tap.partition.BasePartitionTap<Config,Input,Output> | ||
---|---|---|
protected static final int |
OPEN_WRITES_THRESHOLD_DEFAULT |
300 |
cascading.tap.partition.DelimitedPartition | ||
---|---|---|
public static final String |
PATH_DELIM |
"/" |
cascading.tap.partition.PartitionTapProps | ||
---|---|---|
public static final String |
FAIL_ON_CLOSE |
"cascading.tap.partition.failonclose" |
cascading.tuple.* |
---|
cascading.tuple.TupleEntrySchemeIteratorProps | ||
---|---|---|
public static final String |
PERMITTED_EXCEPTIONS |
"cascading.tuple.tupleentryiterator.exceptions.permit" |
cascading.tuple.collect.SpillableProps | ||
---|---|---|
public static final int |
defaultListThreshold |
10000 |
public static final int |
defaultMapInitialCapacity |
100000 |
public static final float |
defaultMapLoadFactor |
0.75f |
public static final int |
defaultMapThreshold |
10000 |
public static final String |
LIST_THRESHOLD |
"cascading.spill.list.threshold" |
public static final String |
MAP_CAPACITY |
"cascading.spill.map.capacity" |
public static final String |
MAP_LOADFACTOR |
"cascading.spill.map.loadfactor" |
public static final String |
MAP_THRESHOLD |
"cascading.spill.map.threshold" |
public static final String |
SPILL_CODECS |
"cascading.spill.codecs" |
public static final String |
SPILL_COMPRESS |
"cascading.spill.compress" |
cascading.tuple.collect.SpillableTupleList | ||
---|---|---|
public static final String |
SPILL_CODECS |
"cascading.spill.codecs" |
public static final String |
SPILL_COMPRESS |
"cascading.spill.compress" |
public static final String |
SPILL_THRESHOLD |
"cascading.spill.list.threshold" |
cascading.tuple.collect.SpillableTupleMap | ||
---|---|---|
public static final String |
MAP_CAPACITY |
"cascading.spill.map.capacity" |
public static final String |
MAP_LOADFACTOR |
"cascading.spill.map.loadfactor" |
public static final String |
MAP_THRESHOLD |
"cascading.spill.map.threshold" |
cascading.tuple.collect.TupleCollectionFactory<Config> | ||
---|---|---|
public static final String |
TUPLE_COLLECTION_FACTORY |
"cascading.factory.tuple.collection.classname" |
cascading.tuple.collect.TupleMapFactory<Config> | ||
---|---|---|
public static final String |
TUPLE_MAP_FACTORY |
"cascading.factory.tuple.map.classname" |
cascading.tuple.hadoop.TupleSerializationProps | ||
---|---|---|
public static final String |
HADOOP_IO_SERIALIZATIONS |
"io.serializations" |
public static final String |
SERIALIZATION_TOKENS |
"cascading.serialization.tokens" |
cascading.tuple.hadoop.collect.HadoopSpillableTupleList | ||
---|---|---|
public static final String |
defaultCodecs |
"org.apache.hadoop.io.compress.GzipCodec,org.apache.hadoop.io.compress.DefaultCodec" |
cascading.tuple.hadoop.io.HadoopTupleOutputStream | ||
---|---|---|
public static final int |
WRITABLE_TOKEN |
32 |
|
|||||||||
PREV NEXT | FRAMES NO FRAMES |