Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
STREAM_PATH_PATTERN |
"deployments/streams/%s/status" |
public static final java.lang.String |
STREAM_STATUS_UNDEPLOYED |
"undeployed" |
public static final java.lang.String |
STREAM_STATUS_UNDEPLOYING |
"undeploying" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_FIELD_NAME_MAPPING_SPLIT_TOKEN |
":" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HSQLDBSERVER_PROFILE |
"hsqldbServer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_ISOLATION_LEVEL |
"ISOLATION_SERIALIZABLE" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ADMIN_ID_KEY |
"id" |
public static final java.lang.String |
HOST_KEY |
"host" |
public static final java.lang.String |
IP_ADDRESS_KEY |
"ip" |
public static final java.lang.String |
MGMT_PORT_KEY |
"managementPort" |
public static final java.lang.String |
PORT_KEY |
"port" |
public static final java.lang.String |
PROCESS_ID_KEY |
"pid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONTAINER_ID_KEY |
"id" |
public static final java.lang.String |
GROUPS_KEY |
"groups" |
public static final java.lang.String |
HOST_KEY |
"host" |
public static final java.lang.String |
IP_ADDRESS_KEY |
"ip" |
public static final java.lang.String |
MGMT_PORT_KEY |
"managementPort" |
public static final java.lang.String |
PROCESS_ID_KEY |
"pid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONSUMER |
"consumer" |
public static final java.lang.String |
DIRECT |
"direct" |
public static final java.lang.String |
PRODUCER |
"producer" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BACK_OFF_INITIAL_INTERVAL |
"backOffInitialInterval" |
public static final java.lang.String |
BACK_OFF_MAX_INTERVAL |
"backOffMaxInterval" |
public static final java.lang.String |
BACK_OFF_MULTIPLIER |
"backOffMultiplier" |
public static final java.lang.String |
BATCH_BUFFER_LIMIT |
"batchBufferLimit" |
public static final java.lang.String |
BATCH_SIZE |
"batchSize" |
public static final java.lang.String |
BATCH_TIMEOUT |
"batchTimeout" |
public static final java.lang.String |
BATCHING_ENABLED |
"batchingEnabled" |
public static final java.lang.String |
COMPRESS |
"compress" |
public static final java.lang.String |
CONCURRENCY |
"concurrency" |
public static final java.lang.String |
COUNT |
"count" |
public static final java.lang.String |
DIRECT_BINDING_ALLOWED |
"directBindingAllowed" |
public static final java.lang.String |
DURABLE |
"durableSubscription" |
public static final java.lang.String |
MAX_ATTEMPTS |
"maxAttempts" |
public static final java.lang.String |
MAX_CONCURRENCY |
"maxConcurrency" |
public static final java.lang.String |
NEXT_MODULE_CONCURRENCY |
"next.module.concurrency" |
public static final java.lang.String |
NEXT_MODULE_COUNT |
"next.module.count" |
public static final java.lang.String |
PARTITION_COUNT |
"partitionCount" |
public static final java.lang.String |
PARTITION_INDEX |
"partitionIndex" |
public static final java.lang.String |
PARTITION_KEY_EXPRESSION |
"partitionKeyExpression" |
public static final java.lang.String |
PARTITION_KEY_EXTRACTOR_CLASS |
"partitionKeyExtractorClass" |
public static final java.lang.String |
PARTITION_SELECTOR_CLASS |
"partitionSelectorClass" |
public static final java.lang.String |
PARTITION_SELECTOR_EXPRESSION |
"partitionSelectorExpression" |
public static final java.lang.String |
SEQUENCE |
"sequence" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TAP_CHANNEL_PREFIX |
"tap:" |
public static final java.lang.String |
TOPIC_CHANNEL_PREFIX |
"topic:" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
JOB_CHANNEL_TYPE_PREFIX |
"job:" |
protected static final java.lang.String |
P2P_NAMED_CHANNEL_TYPE_PREFIX |
"queue:" |
protected static final java.lang.String |
PARTITION_HEADER |
"partition" |
protected static final java.lang.String |
PUBSUB_NAMED_CHANNEL_TYPE_PREFIX |
"topic:" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
REPLY_TO |
"replyTo" |
public static final java.lang.String |
XD_HISTORY |
"xdHistory" |
public static final java.lang.String |
XD_ORIGINAL_CONTENT_TYPE |
"originalContentType" |
public static final java.lang.String |
XD_REPLY_CHANNEL |
"xdReplyChannel" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
FILE_REGISTRATION_ID |
1 |
protected static final int |
TUPLE_REGISTRATION_ID |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
FILE_REGISTRATION_ID |
1 |
protected static final int |
TUPLE_REGISTRATION_ID |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
FILE_REGISTRATION_ID |
1 |
protected static final int |
TUPLE_REGISTRATION_ID |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
FILE_REGISTRATION_ID |
1 |
protected static final int |
TUPLE_REGISTRATION_ID |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
AUTO_COMMIT_ENABLED |
"autoCommitEnabled" |
public static final java.lang.String |
BATCH_SIZE |
"batchSize" |
public static final java.lang.String |
BATCH_TIMEOUT |
"batchTimeout" |
public static final java.lang.String |
BATCHING_ENABLED |
"batchingEnabled" |
public static final java.lang.String |
COMPRESSION_CODEC |
"compressionCodec" |
public static final java.lang.String |
CONCURRENCY |
"concurrency" |
public static final java.lang.String |
FETCH_SIZE |
"fetchSize" |
public static final java.lang.String |
KAFKA_MIN_PARTITION_COUNT |
"minPartitionCount" |
public static final int |
METADATA_VERIFICATION_MAX_INTERVAL |
1000 |
public static final int |
METADATA_VERIFICATION_RETRY_ATTEMPTS |
10 |
public static final double |
METADATA_VERIFICATION_RETRY_BACKOFF_MULTIPLIER |
2.0 |
public static final int |
METADATA_VERIFICATION_RETRY_INITIAL_INTERVAL |
100 |
public static final java.lang.String |
QUEUE_SIZE |
"fetchSize" |
public static final java.lang.String |
REPLICATION_FACTOR |
"replicationFactor" |
public static final java.lang.String |
REQUIRED_ACKS |
"requiredAcks" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ARCHIVE_AS_FILE_EXTENSION |
".jar" |
public static final java.lang.String |
HASH_EXTENSION |
".md5" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
JOB_CHANNEL_PREFIX |
"job:" |
protected static final java.lang.String |
MODULE_INPUT_CHANNEL |
"input" |
protected static final java.lang.String |
MODULE_OUTPUT_CHANNEL |
"output" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
PLUGIN_CONTEXT_CONFIG_ROOT |
"META-INF/spring-xd/plugins/" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
XD_ZOOKEEPER_CLIENT |
"xd.zookeeper.client" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
BATCH_EXCEPTION |
"xd_batch_exception" |
public static final java.lang.String |
BATCH_LISTENER_EVENT_TYPE |
"xd_batch_listener_event_type" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
JOB |
"job" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ABSOLUTE_FILE_PATH |
"absoluteFilePath" |
public static final java.lang.String |
IS_RESTART_JOB_PARAMETER_KEY |
"XD_isRestart" |
public static final java.lang.String |
UNIQUE_JOB_PARAMETER_KEY |
"random" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
JOB_PARAMETERS_KEY |
"jobParameters" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CHUNK_EVENTS_SUFFIX |
"chunk" |
public static final java.lang.String |
ITEM_EVENTS_SUFFIX |
"item" |
public static final java.lang.String |
JOB_EXECUTION_EVENTS_SUFFIX |
"job" |
public static final java.lang.String |
SKIP_EVENTS_SUFFIX |
"skip" |
public static final java.lang.String |
STEP_EXECUTION_EVENTS_SUFFIX |
"step" |
public static final java.lang.String |
XD_AGGREGATED_EVENTS_CHANNEL |
"xd.job.aggregatedEvents" |
public static final java.lang.String |
XD_CHUNK_EVENTS_CHANNEL |
"xd.job.chunkEvents" |
public static final java.lang.String |
XD_CHUNK_LISTENER_BEAN |
"xd.chunkListener" |
public static final java.lang.String |
XD_ITEM_EVENTS_CHANNEL |
"xd.job.itemEvents" |
public static final java.lang.String |
XD_ITEM_LISTENER_BEAN |
"xd.itemListener" |
public static final java.lang.String |
XD_JOB_EXECUTION_EVENTS_CHANNEL |
"xd.job.jobExecutionEvents" |
public static final java.lang.String |
XD_JOB_EXECUTION_LISTENER_BEAN |
"xd.jobExecutionListener" |
public static final java.lang.String |
XD_SKIP_EVENTS_CHANNEL |
"xd.job.skipEvents" |
public static final java.lang.String |
XD_SKIP_LISTENER_BEAN |
"xd.skipListener" |
public static final java.lang.String |
XD_STEP_EXECUTION_EVENTS_CHANNEL |
"xd.job.stepExecutionEvents" |
public static final java.lang.String |
XD_STEP_EXECUTION_LISTENER_BEAN |
"xd.stepExecutionListener" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
MESSAGE_BUS_JARS_LOCATION |
"file:${XD_HOME}/lib/messagebus/${XD_TRANSPORT}/*.jar" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
EMBEDDED_ZK_CONNECT |
"zk.embedded.client.connect" |
public static final java.lang.String |
ZK_CONNECT |
"zk.client.connect" |
public static final java.lang.String |
ZK_PROPERTIES_SOURCE |
"zk-properties" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
QUIET_PERIOD_PROPERTY |
"xd.admin.quietPeriod" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONTAINER_ATTRIBUTES_PREFIX |
"xd.container." |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
QUEUE_PREFIX |
"queue:" |
protected static final java.lang.String |
TOPIC_PREFIX |
"topic:" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
XD_ADMIN_UI_BASE_PATH |
"admin-ui" |
public static final java.lang.String |
XD_BATCH_CONFIG_ROOT |
"META-INF/spring-xd/batch/" |
public static final java.lang.String |
XD_CONFIG_ROOT |
"META-INF/spring-xd/" |
public static final java.lang.String |
XD_INTERNAL_CONFIG_ROOT |
"META-INF/spring-xd/internal/" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ADMIN_PROFILE |
"admin" |
public static final java.lang.String |
CONTAINER_PROFILE |
"container" |
public static final java.lang.String |
SINGLENODE_PROFILE |
"singlenode" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ADMINELECTION |
"adminelection" |
public static final java.lang.String |
ADMINS |
"admins" |
public static final java.lang.String |
ALLOCATED |
"allocated" |
public static final java.lang.String |
CONTAINERS |
"containers" |
public static final java.lang.String |
DEPLOYMENT_QUEUE |
"queue/deployments" |
public static final java.lang.String |
DEPLOYMENTS |
"deployments" |
public static final java.lang.String |
JOB_DEPLOYMENTS |
"deployments/jobs" |
public static final java.lang.String |
JOBS |
"jobs" |
public static final java.lang.String |
METADATA |
"metadata" |
public static final java.lang.String |
MODULE_DEPLOYMENTS |
"deployments/modules" |
public static final java.lang.String |
MODULES |
"modules" |
public static final java.lang.String |
QUEUE |
"queue" |
public static final java.lang.String |
REQUESTED |
"requested" |
public static final java.lang.String |
STATUS |
"status" |
public static final java.lang.String |
STREAM_DEPLOYMENTS |
"deployments/streams" |
public static final java.lang.String |
STREAMS |
"streams" |
public static final java.lang.String |
TAPS |
"taps" |
public static final java.lang.String |
XD_NAMESPACE |
"xd" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_CLIENT_CONNECT_STRING |
"localhost:2181" |
public static final int |
DEFAULT_CONNECTION_TIMEOUT |
30000 |
public static final int |
DEFAULT_INITIAL_RETRY_WAIT |
1000 |
public static final int |
DEFAULT_MAX_RETRY_ATTEMPTS |
3 |
public static final int |
DEFAULT_SESSION_TIMEOUT |
60000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_BASE_FILENAME |
"data" |
public static final java.lang.String |
DEFAULT_BASE_PATH |
"/data/" |
public static final java.lang.String |
DEFAULT_FILE_SUFFIX |
"log" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DATA_PATH |
"/xd" |
public static final java.lang.String |
DEFAULT_ID_FILE_NAMING_STRATEGY |
"fileNamingStrategy" |
public static final java.lang.String |
DEFAULT_ID_FILE_ROLLOVER_STRATEGY |
"fileRolloverStrategy" |
public static final java.lang.String |
DEFAULT_ID_STORE_WRITER |
"storeWriter" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
REACTOR_ENV_BEAN_NAME |
"reactorEnv" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
ADMIN_TOKEN |
"adminNode" |
public static final java.lang.String |
CONTAINER_TOKEN |
"containerNode" |
public static final java.lang.String |
SINGLENODE_TOKEN |
"singleNode" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
TMP_DIR |
"result/" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
HTTP_PREFIX |
"http://" |
public static final java.lang.String |
RESULT_LOCATION |
"/tmp/xd/output" |
public static final java.lang.String |
XD_ADMIN_HOST |
"xd_admin_host" |
public static final java.lang.String |
XD_HTTP_PORT |
"xd_http_port" |
public static final java.lang.String |
XD_JMX_PORT |
"xd_jmx_port" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
COUNT_KEY |
"count" |
public static final java.lang.String |
CRITERIA_KEY |
"criteria" |
public static final java.lang.String |
TRACK_HISTORY_KEY |
"trackHistory" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SEQUENCE_KEY |
"sequence" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
OPTION_SEPARATOR |
"." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
MODULE_EXECUTION_FRAMEWORK_KEY |
"moduleExecutionFramework" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
OPTIONS_CLASS |
"options_class" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
NO_DEFAULT |
"__NULL__" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
XD_CONTAINER_KEY_PREFIX |
"xd.container." |
public static final java.lang.String |
XD_GROUP_NAME_KEY |
"xd.group.name" |
public static final java.lang.String |
XD_JOB_NAME |
"${xd.job.name}" |
public static final java.lang.String |
XD_JOB_NAME_KEY |
"xd.job.name" |
public static final java.lang.String |
XD_MODULE_COUNT_KEY |
"xd.module.count" |
public static final java.lang.String |
XD_MODULE_INDEX |
"${xd.module.index}" |
public static final java.lang.String |
XD_MODULE_INDEX_KEY |
"xd.module.index" |
public static final java.lang.String |
XD_MODULE_LABEL |
"${xd.module.label}" |
public static final java.lang.String |
XD_MODULE_LABEL_KEY |
"xd.module.label" |
public static final java.lang.String |
XD_MODULE_NAME |
"${xd.module.name}" |
public static final java.lang.String |
XD_MODULE_NAME_KEY |
"xd.module.name" |
public static final java.lang.String |
XD_MODULE_SEQUENCE_KEY |
"xd.module.sequence" |
public static final java.lang.String |
XD_MODULE_TYPE |
"${xd.module.type}" |
public static final java.lang.String |
XD_MODULE_TYPE_KEY |
"xd.module.type" |
public static final java.lang.String |
XD_STREAM_NAME |
"${xd.stream.name}" |
public static final java.lang.String |
XD_STREAM_NAME_KEY |
"xd.stream.name" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
MESSAGE_BUS_JARS_LOCATION |
"file:${XD_HOME}/lib/messagebus/${XD_TRANSPORT}/*.jar" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_XD_DATE_FORMAT_PATTERN |
"yyyy-MM-dd" |
public static final java.lang.String |
DEFAULT_XD_DATE_TIME_FORMAT_PATTERN |
"yyyy-MM-dd HH:mm:ss,SSS" |
public static final java.lang.String |
DEFAULT_XD_DURATION_FORMAT_PATTERN |
"HH:mm:ss" |
public static final java.lang.String |
DEFAULT_XD_TIME_FORMAT_PATTERN |
"HH:mm:ss" |
public static final java.lang.String |
DEFAULT_XD_TIMEZONE_ID |
"UTC" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_HOST |
"localhost" |
public static final int |
DEFAULT_PORT |
9393 |
public static final java.lang.String |
DEFAULT_SCHEME |
"http" |
public static final java.lang.String |
DEFAULT_SPECIFIED_PASSWORD |
"" |
public static final java.lang.String |
DEFAULT_TARGET |
"http://localhost:9393/" |
public static final java.lang.String |
DEFAULT_UNSPECIFIED_PASSWORD |
"__NULL__" |
public static final java.lang.String |
DEFAULT_USERNAME |
"" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT |
"<use platform locale>" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
NOT_AVAILABLE |
"N/A" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
COLUMN_1 |
1 |
public static final int |
COLUMN_2 |
2 |
public static final int |
COLUMN_3 |
3 |
public static final int |
COLUMN_4 |
4 |
public static final int |
COLUMN_5 |
5 |
public static final int |
COLUMN_6 |
6 |
public static final java.lang.String |
HORIZONTAL_LINE |
"-------------------------------------------------------------------------------\n" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
MODULE_EXECUTION_FRAMEWORK |
"spark" |
public static final java.lang.String |
SPARK_DEFAULT_MASTER_URL |
"spark://localhost:7077" |
public static final java.lang.String |
SPARK_DEFAULT_STORAGE_LEVEL |
"MEMORY_ONLY" |
public static final java.lang.String |
SPARK_MASTER_URL_PROP |
"spark.master" |
public static final java.lang.String |
SPARK_STORAGE_LEVEL_MODULE_OPTION |
"storageLevel" |
public static final java.lang.String |
SPARK_STORAGE_LEVEL_PROP |
"spark.storageLevel" |
public static final java.lang.String |
SPARK_STREAMING_BATCH_INTERVAL_MODULE_OPTION |
"batchInterval" |
public static final java.lang.String |
SPARK_STREAMING_BATCH_INTERVAL_PROP |
"spark.streaming.batchInterval" |
public static final java.lang.String |
SPARK_STREAMING_DEFAULT_BATCH_INTERVAL |
"2000" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
SECURITY_AUTH_METHOD |
"security.authMethod" |
public static final java.lang.String |
SECURITY_MAPREDUCE_JOBHISTORY_PRINCIPAL |
"security.jobHistoryPrincipal" |
public static final java.lang.String |
SECURITY_NAMENODE_PRINCIPAL |
"security.namenodePrincipal" |
public static final java.lang.String |
SECURITY_RM_MANAGER_PRINCIPAL |
"security.rmManagerPrincipal" |
public static final java.lang.String |
SECURITY_USER_KEYTAB |
"security.userKeytab" |
public static final java.lang.String |
SECURITY_USER_PRINCIPAL |
"security.userPrincipal" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
XD_EXTERNAL_SERVERS_REQUIRED |
"XD_EXTERNAL_SERVERS_REQUIRED" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
ADMIN_PASSWORD |
"secret" |
protected static final java.lang.String |
ADMIN_USER |
"johndoe" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"filejdbctest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"filejdbctest.out" |
public static final java.lang.String |
DEFAULT_NAMES |
"data" |
public static final java.lang.String |
DEFAULT_TABLE_NAME |
"filejdbctest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/filepollhdfsjob" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"filePollHdfsJob" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_HOST_NAME |
"localhost" |
public static final java.lang.String |
DEFAULT_PORT |
"4444" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/hdfsjdbctest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"hdfsjdbctest" |
public static final java.lang.String |
DEFAULT_NAMES |
"data" |
public static final java.lang.String |
DEFAULT_TABLE_NAME |
"hdfsjdbctest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_COLLECTION_NAME |
"hdfsmongodbtest" |
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/hdfsmongodbtest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"hdfsmongodbtest" |
public static final java.lang.String |
DEFAULT_ID_FIELD |
"data" |
public static final java.lang.String |
DEFAULT_NAMES |
"data" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/acceptancetest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"ACCTEST" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_DIRECTORY |
"/xd/jdbchdfstest" |
public static final java.lang.String |
DEFAULT_FILE_NAME |
"jdbchdfstest" |
public static final java.lang.String |
DEFAULT_SQL |
"select payload from jdbchdfstest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_PORT |
61616 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_BROKER_LIST |
"localhost:9092" |
public static final java.lang.String |
DEFAULT_TOPIC |
"mytopic" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_OUTPUT_TYPE |
"text/plain" |
public static final java.lang.String |
DEFAULT_TOPIC |
"mytopic" |
public static final java.lang.String |
DEFAULT_ZK_CLIENT |
"localhost:2181" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_COLUMN_NAMES |
"id,name" |
public static final java.lang.String |
DEFAULT_PARTITION_COLUMN |
"id" |
public static final int |
DEFAULT_PARTITIONS |
3 |
public static final java.lang.String |
DEFAULT_TABLE |
"jdbchdfstest" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_ADDRESSES |
"localhost:5672" |
public static final java.lang.String |
DEFAULT_EXCHANGE |
"RabbitSource" |
public static final java.lang.String |
DEFAULT_ROUTING_KEY |
"rabbitfixture.rabbit_sink" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_EXCHANGE |
"RabbitSource" |
public static final java.lang.String |
DEFAULT_QUEUE |
"rabbit_source" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_MODE |
"REPLACE" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_APP_JAR |
"/home/ubuntu/application-test-sparkapp-1.1.0.BUILD-SNAPSHOT.jar" |
public static final java.lang.String |
DEFAULT_APP_SOURCE_JAR |
"/tmp/application-test-sparkapp-1.1.0.BUILD-SNAPSHOT.jar" |
public static final java.lang.String |
DEFAULT_MAIN_CLASS |
"spark.SparkPi" |
public static final java.lang.String |
DEFAULT_MASTER |
"localhost[1]" |
public static final java.lang.String |
DEFAULT_NAME |
"EC2TEST3SPARKNAME" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_HOST |
"localhost" |
public static final int |
DEFAULT_PORT |
5140 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
DEFAULT_HOST |
"localhost" |
public static final int |
DEFAULT_PORT |
5140 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
XD_ADMINS |
"admins" |
public static final java.lang.String |
ZK_CLIENT_CONNECT |
"zk.client.connect" |
public static final java.lang.String |
ZK_NAMESPACE |
"zk.namespace" |