Constant Field Values


Contents
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 DEBUG_LEVEL "cascading.flowconnector.debuglevel"
public static final String INTERMEDIATE_SCHEME_CLASS "cascading.flowconnector.intermediateschemeclass"

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.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_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.util.Hadoop18TapUtil
public static final String TEMPORARY_PATH "_temporary"

cascading.tuple.*

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



Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.