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.