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 |
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 |
PROCESS_ID_KEY |
"pid" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final java.lang.String |
CONSUMER |
"consumer" |
public static final java.lang.String |
PRODUCER |
"producer" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
JOB_CHANNEL_TYPE_PREFIX |
"job:" |
protected static final java.lang.String |
ORIGINAL_CONTENT_TYPE_HEADER |
"originalContentType" |
protected static final java.lang.String |
P2P_NAMED_CHANNEL_TYPE_PREFIX |
"queue:" |
protected static final java.lang.String |
PUBSUB_NAMED_CHANNEL_TYPE_PREFIX |
"topic:" |
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" |
protected static final java.lang.String |
TAP_CHANNEL_PREFIX |
"tap:" |
protected static final java.lang.String |
TOPIC_CHANNEL_PREFIX |
"topic:" |
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 |
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 |
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 |
ERROR_DESCRIPTION_KEY |
"errorDescription" |
public static final java.lang.String |
STATUS_KEY |
"status" |
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" |
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_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 |
CLOUD_PROFILE |
"cloud" |
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 |
ADMINS |
"admins" |
public static final java.lang.String |
CONTAINERS |
"containers" |
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 |
MODULE_DEPLOYMENTS |
"deployments/modules" |
public static final java.lang.String |
MODULES |
"modules" |
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" |
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_CONTAINERS |
"xd_containers" |
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" |
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 |
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_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_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_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 |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final java.lang.String |
DEPLOYMENTS_URI |
"/_deployments" |
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_TARGET |
"http://localhost:9393/" |
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 |
---|---|---|
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_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.out" |
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_EXCHANGE |
"RabbitSource" |
public static final java.lang.String |
DEFAULT_HOST |
"localhost" |
public static final int |
DEFAULT_PORT |
5672 |
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_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 |