Constant Field Values

Contents

• cascading.cascade.*
• cascading.flow.*
• cascading.management.*
• cascading.operation.*
• cascading.pipe.*
• cascading.property.*
• cascading.scheme.*
• cascading.stats.*
• cascading.tap.*
• cascading.tuple.*

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