Constant Field Values

Contents

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

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.stream.OperatorStage<Incoming>

public static final String

RETAIN_COLLECTOR

"cascading.compatibility.retain.collector"

cascading.flow.stream.StreamGraph

public static final String	DOT_FILE_PATH	"cascading.stream.dotfile.path"
public static final String	ERROR_DOT_FILE_NAME	"cascading.stream.error.dotfile"

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.stats.*

cascading.stats.CascadingStats

public static final String

STATS_STORE_INTERVAL

"cascading.stats.store.interval"

cascading.tap.*

cascading.tap.BaseTemplateTap<Config,Output>

protected static final int

OPEN_TAPS_THRESHOLD_DEFAULT

300

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.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.util.*

cascading.util.Update

public static final String	UPDATE_CHECK_SKIP	"cascading.update.skip"
public static final String	UPDATE_URL	"cascading.update.url"

cascading.util.Version

public static final String	CASCADING	"Cascading"
public static final String	CASCADING_BUILD_NUMBER	"cascading.build.number"
public static final String	CASCADING_RELEASE_MAJOR	"cascading.release.major"
public static final String	CASCADING_RELEASE_MINOR	"cascading.release.minor"