| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | CRUNCH_FILTER_NAME | "crunch.filter.name" | 
| public static final String | CRUNCH_FILTER_SIZE | "crunch.filter.size" | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | CRUNCH_INPUTS | "crunch.inputs.dir" | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | CRUNCH_DISABLE_OUTPUT_COUNTERS | "crunch.disable.output.counters" | 
| public static final String | CRUNCH_OUTPUTS | "crunch.outputs.dir" | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final long | CONSUMER_POLL_TIMEOUT_DEFAULT | 1000L | 
| public static final String | CONSUMER_POLL_TIMEOUT_KEY | "org.apache.crunch.kafka.consumer.poll.timeout" | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | KAFKA_EMPTY_RETRY_ATTEMPTS_KEY | "org.apache.crunch.kafka.retry.empty.attempts" | 
| public static final int | KAFKA_RETRY_ATTEMPTS_DEFAULT | 5 | 
| public static final String | KAFKA_RETRY_ATTEMPTS_KEY | "org.apache.crunch.kafka.retry.attempts" | 
| public static final int | KAFKA_RETRY_EMPTY_ATTEMPTS_DEFAULT | 10 | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | FILE_FORMAT_EXTENSION | ".json" | 
| public static final String | PERSIST_TIME_FORMAT | "yyyy-MM-dd\'T\'HH-mm-ssZ" | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | DEFAULT_PATH | "_partition.lst" | 
| public static final String | PARTITIONER_PATH | "crunch.totalorderpartitioner.path" | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | AVRO_MODE_PROPERTY | "crunch.avro.mode" | 
| public static final String | AVRO_SHUFFLE_MODE_PROPERTY | "crunch.avro.shuffle.mode" | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | REFLECT_DATA_FACTORY_CLASS | "crunch.reflectdatafactory" | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | DIST_CACHE_REPLICATION | "crunch.distcache.replication" | 
| Modifier and Type | Constant Field | Value | 
|---|---|---|
| public static final String | BYTES_PER_REDUCE_TASK | "crunch.bytes.per.reduce.task" | 
| public static final long | DEFAULT_BYTES_PER_REDUCE_TASK | 1000000000L | 
| public static final int | DEFAULT_MAX_REDUCERS | 500 | 
| public static final String | MAX_REDUCERS | "crunch.max.reducers" | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.